Method executePermissionAndRespond

go/session.go:1556–1598

executePermissionAndRespond executes a permission handler and sends the result back via RPC.

(requestID string, permissionRequest PermissionRequest, handler PermissionHandlerFunc)

// executePermissionAndRespond executes a permission handler and sends the result back via RPC.
func (s *Session) executePermissionAndRespond(requestID string, permissionRequest PermissionRequest, handler PermissionHandlerFunc) {
	defer func() {
		if r := recover(); r != nil {
			s.RPC.Permissions.HandlePendingPermissionRequest(context.Background(), &rpc.PermissionDecisionRequest{
				RequestID: requestID,
				Result:    &rpc.PermissionDecisionUserNotAvailable{},
			})
		}
	}()

	invocation := PermissionInvocation{
		SessionID: s.SessionID,
	}

	decision, err := handler(permissionRequest, invocation)
	if err != nil {
		s.RPC.Permissions.HandlePendingPermissionRequest(context.Background(), &rpc.PermissionDecisionRequest{
			RequestID: requestID,
			Result:    &rpc.PermissionDecisionUserNotAvailable{},
		})
		return
	}
	if decision == nil {
		// Handler returned (nil, nil); treat as user-not-available rather
		// than sending null on the wire.
		s.RPC.Permissions.HandlePendingPermissionRequest(context.Background(), &rpc.PermissionDecisionRequest{
			RequestID: requestID,
			Result:    &rpc.PermissionDecisionUserNotAvailable{},
		})
		return
	}
	if _, ok := decision.(*rpc.PermissionDecisionNoResult); ok {
		return
	}
	if _, ok := decision.(rpc.PermissionDecisionNoResult); ok {
		return
	}

	s.RPC.Permissions.HandlePendingPermissionRequest(context.Background(), &rpc.PermissionDecisionRequest{
		RequestID: requestID,
		Result:    decision,
	})
}

// GetEvents retrieves all events from this session's history.
//