Method handleStateReadRequest

lib/plugin.go:313–353

HandleStateReadRequest() handles an inbound state read request from a specific FSM context

(msg *PluginToFSM)

// HandleStateReadRequest() handles an inbound state read request from a specific FSM context
func (p *Plugin) handleStateReadRequest(msg *PluginToFSM) ErrorI {
	// debug log state read request start
	p.log.Debugf("handleStateReadRequest() processing message ID %d", msg.Id)
	// get the FSM context for this request ID
	p.l.Lock()
	fsm := p.requestFSMs[msg.Id]
	// debug log FSM lookup
	p.log.Debugf("handleStateReadRequest() FSM lookup for ID %d: found=%t, total_fsms=%d", msg.Id, fsm != nil, len(p.requestFSMs))
	p.l.Unlock()
	// debug log request details
	request := msg.GetStateRead()
	p.log.Debugf("handleStateReadRequest() state read request: %+v", request)
	// check if FSM context exists
	if fsm == nil {
		p.log.Debugf("handleStateReadRequest() no FSM context found for request ID %d", msg.Id)
		return ErrInvalidPluginRespId()
	}
	// forward request to the appropriate FSM
	p.log.Debug("handleStateReadRequest() forwarding request to FSM")
	response, err := fsm.StateRead(request)
	if err != nil {
		p.log.Debugf("handleStateReadRequest() FSM StateRead error: %v", err)
		response.Error = NewPluginError(err)
	} else {
		p.log.Debugf("handleStateReadRequest() FSM StateRead success: %+v", response)
	}
	// send response back to FSM
	p.log.Debugf("handleStateReadRequest() sending response back for message ID %d", msg.Id)
	sendErr := p.sendProtoMsg(&FSMToPlugin{
		Id: msg.Id,
		Payload: &FSMToPlugin_StateRead{
			StateRead: &response,
		},
	})
	if sendErr != nil {
		p.log.Debugf("handleStateReadRequest() error sending response: %v", sendErr)
	} else {
		p.log.Debug("handleStateReadRequest() response sent successfully")
	}
	return sendErr
}

// HandleStateWriteRequest() handles an inbound state write request from a specific FSM context
func (p *Plugin) handleStateWriteRequest(msg *PluginToFSM) ErrorI {