Method ProcessUnary

erpc/request_processor.go:35–67

(
	ctx context.Context,
	input *RequestInput,
	rawJSONRPC json.RawMessage,
)

}

func (rp *RequestProcessor) ProcessUnary(
	ctx context.Context,
	input *RequestInput,
	rawJSONRPC json.RawMessage,
) (*common.NormalizedResponse, error) {
	project, err := rp.erpc.GetProject(input.ProjectId)
	if err != nil {
		return nil, err
	}

	nq := common.NewNormalizedRequest(rawJSONRPC)
	if err := nq.Validate(); err != nil {
		return nil, err
	}

	nq.SetClientIP(input.ClientIP)
	method, _ := nq.Method()
	user, err := project.AuthenticateConsumer(ctx, nq, method, input.AuthPayload)
	if err != nil {
		return nil, err
	}
	nq.SetUser(user)

	networkID := fmt.Sprintf("%s:%s", input.Architecture, input.ChainId)
	network, err := project.GetNetwork(ctx, networkID)
	if err != nil {
		return nil, err
	}
	nq.SetNetwork(network)
	nq.ApplyDirectiveDefaults(network.Config().DirectiveDefaults)

	return project.Forward(ctx, networkID, nq)
}

func (rp *RequestProcessor) ProcessQueryStream(
	ctx context.Context,