if multiple users are login then my messages are getting mixed up for multiple users(managing session is a problem) this is my server side

[Neeleshpandya]

import socketio
import uvicorn

sio = socketio.AsyncServer(async_mode='asgi')
app = socketio.ASGIApp(sio)

@sio.event
async def connect(sid, environ):
    
    username= environ.get('HTTP_X_USERNAME')
    print(sid, "connected")


    async with sio.session(sid) as session:
        session['username'] = username
    print(session)

@sio.event
async def greet(sid, data):
    async with sio.session(sid) as session:
        user_nm = session['username']
    msg = "Hello {}, what do you want to build today".format(user_nm)
    await sio.emit('disconnect', to=sid)
    #return {'msg' : msg}

@sio.event
async def disconnect(sid):
    print(sid, "disconnected")

if __name__ == '__main__':
    uvicorn.run(app, host='0.0.0.0', port=8005)

[miguelgrinberg]

Please do not use the issues board to ask questions about your applications. The discussions board is the right place to ask about your own code.

Looking at your code I cannot see where you have a problem with mixed up messages. Please provide more details.

[Neeleshpandya]

if one user is connected its working fine but if multiple users are connected then there inputs are broadcast-ed to other users also

[miguelgrinberg]

You need to be specific. Please show me which line of the code above is having this problem. Also include logs. See the troubleshooting section of the docs to learn how to enable logging if you don't know.

[Neeleshpandya]

@miguelgrinberg thanks for you response i will be more specific,
suppose two user are connected concurrently if one user has been asked what do you want to build today ? he answered movie recommendation
another user came and connected answered the same question as security system , so whats happening is it over rights the previous input and the only user input left is security system ,
i have no error in the logs ,but my issue is every user should have different session but its not happening

[miguelgrinberg]

You continue to be vague. There is nothing in the code that you showed above that fits the description of your problem. I'm going to repeat what I said above:

• Show me which line of code has the problematic emit
• Include logs showing the emit that is being broadcast instead of being sent to a single user

[Neeleshpandya]

@miguelgrinberg thanks for your reply i need to manage session in python socketio if multiple user are logged in then the session is getting mixed up i need to build a app which will have some predefined question asked by the user but whats happening when two users are logged in concurrently there answers are getting mixed up

[miguelgrinberg]

You've indicated what you need several times already. I understand this.

What you are not doing is showing me the code that isn't working according to your needs. Until you do that I will not be able to help.

[Neeleshpandya]

'''import json
import time
import socketio
import uvicorn


sio = socketio.AsyncServer(async_mode='asgi',cors_allowed_origins="*",ping_interval=15000)
app = socketio.ASGIApp(sio,static_files={'/health_check':'./health.html'})

# For GSI
SubSector=json.load(open(r"subsector.json", encoding="utf-8"))
solutionname=''
gsi_txnTimeRights = []          # Done

@sio.event
async def connect(sid, environ):
    username= environ.get('HTTP_X_USERNAME')
    print(sid, "connected")


    async with sio.session(sid) as session:
        session['username'] = username
    print(session)

@sio.event
async def greet(sid, data):
    print('greet')
    async with sio.session(sid) as session:
        user_nm = session['username']
    display="Welcome <strong>{}</strong>. Happy to see you here.\nLets Build the Solution, ".format(user_nm)
    msg = "Can you tell the Name of the Solution/Application that you want to build?"
    await sio.emit('rsp_Client_Event',
                       {'msg':msg,
                        'display':display,
                        'conditional':False,
                        'nextEvent':{'getEvent':'get_soln_nm'}}, to=sid)

@sio.event
async def get_soln_nm(sid, data):
    print('get_soln_nm')
    print(data,'\n')
    global gsi_name,solutionname

    async with sio.session(sid) as session:
        session["soln_name"] = data["User_input"]
    gsi_name = session["soln_name"]
    solutionname=data['User_input']
    msg1="Please help us in choosing the Industry or Sector for the <strong>{}</strong> :"
    msg = msg1.format(session["soln_name"])
    option=list(json.load(open(r'subsector.json', encoding="utf-8")).keys())
    print(msg)
    await sio.emit('rsp_Client_Event',
                   {'msg':msg,
                    'option':option,
                    'conditional':False,
                    'nextEvent':{'getEvent':'get_ind_sector'}}, to=sid)
@sio.event
async def get_ind_sector(sid, data):
    global solutionname,SubSector
    print('\nget_ind_sector')
    print(data,'\n')
    industryInput=data['User_input'].upper()
    msg1="Now, choose the Sub-Sector in the <strong>{}</strong> for <strong>{}</strong>: "
    msg = msg1.format(industryInput,solutionname)
    option=list(SubSector[industryInput])
    print(msg)
    await sio.emit('rsp_Client_Event',
                   {'msg':msg,
                    'option':option,
                    'conditional':False,
                    'nextEvent':{'getEvent':'get_ind_cat'}}, to=sid)

@sio.event
async def get_ind_cat(sid, data):
    global solutionname
    print('get_ind_cat')
    print(data,'\n')
    async with sio.session(sid) as session:
        session["ind_cat"] = data["User_input"]
    msg = "Also , Select the Functional Area for the <strong>{}</strong>:".format(solutionname)
    option=['Administrative',
            'Customer Service',
            'Distribution',
            'Finance',
            'Human Resources',
            'ICT',
            'Marketing',
            'Sales',
            'Production',
            'Research and Development (R & D)'
            ]
    print(msg)
    await sio.emit('rsp_Client_Event',
                   {'msg':msg,
                    'option':option,
                    'conditional':False,
                    'nextEvent':{'getEvent':'get_func_area'}}, to=sid)
@sio.event
async def get_func_area(sid, data):
    global solutionname
    print('get_func_area')
    print(data,'\n')
    async with sio.session(sid) as session:
        session["func_area"] = data["User_input"]
    msg = "Great, Let me understand the Purpose of the <strong>{}</strong>:".format(solutionname)
    print(msg)
    await sio.emit('rsp_Client_Event', {'msg':msg,
                                        'conditional':False,
                                        'nextEvent':{'getEvent':'get_soln_user'}}, to=sid)
    #return {'msg' : msg}

@sio.event
async def get_soln_user(sid, data):
    global solutionname
    print('get_soln_user')
    print(data,'\n')
    async with sio.session(sid) as session:
        session["soln_purpose"] = data["User_input"]
    # gsi_description = session["soln_purpose"]
    msg ="Who are the users of the  <strong>{}</strong>?".format(solutionname)
    print(msg)
    await sio.emit('rsp_Client_Event',
                   {'msg':msg,
                    'conditional':False,
                    'nextEvent':{'getEvent':'get_soln_edit'}}, to=sid)

@sio.event
async def get_soln_edit(sid, data):
    print('get_soln_edit')
    print(data,'\n')
    global gsi_txnTimeRights,solutionname
    async with sio.session(sid) as session:
        session["sol_user"]= data["User_input"]
    sol_user = session["sol_user"]
    sol_user = sol_user.split(",")
    gsi_txnTimeRights = sol_user
    # gsi_description = session["soln_purpose"]
    msg ="Who can edit the  <strong>{}</strong>?".format(solutionname)
    print(msg)
    await sio.emit('disconnect',
                   {'msg':msg,
                    'conditional':False,}, to=sid)

@sio.event
async def disconnect(sid):
    print(sid, "disconnected")



if __name__ == '__main__':
    uvicorn.run('app:app', host='0.0.0.0', port=8005,log_level="info")'''

[Neeleshpandya]

#this is my client
<!DOCTYPE html>
<html>
<head>
    <title>Socket IO POC</title>
</head>
<body>
    <h1> Socket IO POC - wow</h1>
    <script src="https://cdn.socket.io/4.5.0/socket.io.min.js" integrity="sha384-7EyYLQZgWBi67fBtVxw60/OWl1kjsfrPFcaU0pp0nAh+i8FD068QogUvg85Ewy1k" crossorigin="anonymous"></script>
    <script >const sio =io("http://127.0.0.1:8005", {
        transportOptions :{
           polling: {
               extraHeaders:{
                   'X-Username': window.prompt("Whats Your name?")
                   //'X-Authtoken': window.prompt("Enter AuthToken:")ss
               }
           }
       },
        transports: ['websocket', 'polling'],
    
    
    }
    );
     

sio.on('connect',() => {
    var user_nm ;
    console.log("connected")
    sio.emit('greet', {"user": user_nm});
 });

sio.on('rsp_Client_Event', (data) => {
    console.log(data["msg"],data['option'])
    console.log('rsp_Inform_obj_Yes_23')
    Inform_obj_Yes = window.prompt(data['msg'],data['option'])
    console.log("you entered ", Inform_obj_Yes)
    sio.emit(data['nextEvent']['getEvent'], {"User_input": Inform_obj_Yes});
});

sio.on('rsp_each_step_entity', (data) => {
})

sio.on('disconnect',() => {
    console.log("disconnected");
});
    
    </script>
    
</body>


</html>``

[Neeleshpandya]

[Neeleshpandya]

(dinesh) PS C:\Users\NH1305\Desktop\Guni> python app.py
←[32mINFO←[0m:     Started server process [←[36m8588←[0m]
←[32mINFO←[0m:     Waiting for application startup.
←[32mINFO←[0m:     Application startup complete.
←[32mINFO←[0m:     Uvicorn running on ←[1mhttp://0.0.0.0:8005←[0m (Press CTRL+C to quit)
←[32mINFO←[0m:     ('127.0.0.1', 57390) - "WebSocket /socket.io/" [accepted]
←[32mINFO←[0m:     connection open
BSnoY0M6u1HXAbGnAAAB connected
{'username': None}
greet
←[32mINFO←[0m:     ('127.0.0.1', 57391) - "WebSocket /socket.io/" [accepted]
←[32mINFO←[0m:     connection open
z5NlIdzJeUvM51sIAAAD connected
{'username': None}
greet
get_soln_nm
{'User_input': 'movies'}

Please help us in choosing the Industry or Sector for the <strong>movies</strong> :
get_soln_nm
{'User_input': 'transformer'}

Please help us in choosing the Industry or Sector for the <strong>transformer</strong> :

get_ind_sector
{'User_input': 'AGRICULTURE, ANIMAL HUSBANDRY & FORESTRY'}

Now, choose the Sub-Sector in the <strong>AGRICULTURE, ANIMAL HUSBANDRY & FORESTRY</strong> for <strong>transformer</strong>:
get_ind_cat
{'User_input': 'Growing and manufacturing of tea,Growing and manufacturing of coffee,Growing and manufacturing of rubber,Market gardening and horticulture specialties,Raising of silk worms and production of silk,Raising of bees and production of honey,Raising of poultry and production of eggs,Rearing of sheep and production of wool,Rearing of animals and production of animal products,Agricultural and animal husbandry services,Soil conservation, soil testing and soil desalination services,Hunting, trapping and game propagation services,Growing of timber, plantation, operation of tree nurseries and conserving of forest,Gathering of tendu leaves,Gathering of other wild growing materials,Forestry service activities, timber cruising, afforestation and reforestation,Logging service activities, transport of logs within the forest,Other agriculture, animal husbandry or forestry activity n.e.c'}

Also , Select the Functional Area for the <strong>transformer</strong>:

get_ind_sector
{'User_input': 'AGRICULTURE, ANIMAL HUSBANDRY & FORESTRY'}

Now, choose the Sub-Sector in the <strong>AGRICULTURE, ANIMAL HUSBANDRY & FORESTRY</strong> for <strong>transformer</strong>:
get_ind_cat
{'User_input': 'Growing and manufacturing of tea,Growing and manufacturing of coffee,Growing and manufacturing of rubber,Market gardening and horticulture specialties,Raising of silk worms and production of silk,Raising of bees and production of honey,Raising of poultry and production of eggs,Rearing of sheep and production of wool,Rearing of animals and production of animal products,Agricultural and animal husbandry services,Soil conservation, soil testing and soil desalination services,Hunting, trapping and game propagation services,Growing of timber, plantation, operation of tree nurseries and conserving of forest,Gathering of tendu leaves,Gathering of other wild growing materials,Forestry service activities, timber cruising, afforestation and reforestation,Logging service activities, transport of logs within the forest,Other agriculture, animal husbandry or forestry activity n.e.c'}

Also , Select the Functional Area for the <strong>transformer</strong>:

[Neeleshpandya]

this is my logs

[Neeleshpandya]

Transformer is for second client but its showing in other client also

[miguelgrinberg]

You are using a global variable to store this transformer value. I really don't see what this has to do with this package, the global variable is going to affect all your clients, since it is global. What am I missing here?

[Neeleshpandya]

How to store these global variable to a session

[miguelgrinberg]

I really don't have the context regarding your application to give you exact instructions, sorry. But you are already using the user session to store variables. How is this one variable different?

[Neeleshpandya]

Thanks @miguelgrinberg it worked for me i store these global variable in a dictionary making sid as key it worked thanks