Vfrdtyky

This is my code, i want to publish a text file in server and also subscribe the same file by client,here i wrote two programs one is server and another one is client but i don't know how to publish a file using with wamp autobahn python, so can any one please guide me how to publish and subscribe a file.

Server program:

from __future__ import print_function

import requests

from os import environ

import os

import argparse

from twisted.internet import reactor

from twisted.internet.defer import inlineCallbacks

from autobahn.twisted.wamp import ApplicationSession, ApplicationRunner

requests.post("http://wamp.sice.in:8080/notify",

        json={

          'topic': 'service.self.admin',

           'args': [{'type' : 'scrap' }]



        }

    )

class ClientSession(ApplicationSession):

    @inlineCallbacks

    def onJoin(self, details):

        print("session attached")

        self.received = 0

        sub = yield self.subscribe(self.on_event, u'service.self.result')

        print("Service.self.result {}".format(sub.id))



    def on_event(self, i):

        print("Got event: {}".format(i))



    def onDisconnect(self):

        print("disconnected")

        if reactor.running:

            reactor.stop()

if __name__ == '__main__':

    import six



    runner = ApplicationRunner(url= u'ws://wamp.sice.in:8080/ws', realm= u'default')

    runner.run(ClientSession, auto_reconnect=True)

Client program:

from __future__ import print_function

from os import environ

import os

import argparse

from twisted.internet import reactor

from twisted.internet.defer import inlineCallbacks

from autobahn.twisted.wamp import ApplicationSession, ApplicationRunner

import requests

class ClientSession(ApplicationSession):

    @inlineCallbacks

    def onJoin(self, details):

        print("session attached")

        self.received = 0

        sub = yield self.subscribe(self.on_event, u'service.self.admin')

        print("Service.self.adminh {}".format(sub.id))

    def on_event(self, i):

        print("Got event: {}".format(i))

        requests.post("http://wamp.sice.in:8080/notify",

                json={

                  'topic': 'service.self.result',





                  'args':[{'site1':'data'}]                   

            )

    def onDisconnect(self):

        print("disconnected")

        if reactor.running:

            reactor.stop()

if __name__ == '__main__':

    import six



    runner = ApplicationRunner(url= u'ws://wamp.sice.in:8080/ws', realm= u'default')

    runner.run(ClientSession, auto_reconnect=True)