Function QueryLatestEventsAndState

roomserver/internal/helpers/helpers.go:403–456

(
	ctx context.Context, db storage.Database,
	request *api.QueryLatestEventsAndStateRequest,
	response *api.QueryLatestEventsAndStateResponse,
)

}

func QueryLatestEventsAndState(
	ctx context.Context, db storage.Database,
	request *api.QueryLatestEventsAndStateRequest,
	response *api.QueryLatestEventsAndStateResponse,
) error {
	//util.GetLogger(ctx).WithField("request.RoomID", request.RoomID).Info("QueryLatestEventsAndState 111111")
	roomInfo, err := db.RoomInfo(ctx, request.RoomID)
	if err != nil {
		return err
	}
	//util.GetLogger(ctx).WithField("roomInfo", roomInfo).Info("QueryLatestEventsAndState 222222")
	if roomInfo == nil || roomInfo.IsStub() {
		response.RoomExists = false
		return nil
	}
	//util.GetLogger(ctx).Info("QueryLatestEventsAndState 333333")
	roomState := state.NewStateResolution(db, roomInfo)
	response.RoomExists = true
	response.RoomVersion = roomInfo.RoomVersion
	//util.GetLogger(ctx).Info("QueryLatestEventsAndState 444444")
	var currentStateSnapshotNID types.StateSnapshotNID
	response.LatestEvents, currentStateSnapshotNID, response.Depth, err =
		db.LatestEventIDs(ctx, roomInfo.RoomNID)
	if err != nil {
		return err
	}
	//util.GetLogger(ctx).Info("QueryLatestEventsAndState 555555")
	var stateEntries []types.StateEntry
	if len(request.StateToFetch) == 0 {
		// Look up all room state.
		stateEntries, err = roomState.LoadStateAtSnapshot(
			ctx, currentStateSnapshotNID,
		)
	} else {
		// Look up the current state for the requested tuples.
		stateEntries, err = roomState.LoadStateAtSnapshotForStringTuples(
			ctx, currentStateSnapshotNID, request.StateToFetch,
		)
	}
	if err != nil {
		return err
	}
	//util.GetLogger(ctx).Info("QueryLatestEventsAndState 666666")
	stateEvents, err := LoadStateEvents(ctx, db, stateEntries)
	if err != nil {
		return err
	}
	//util.GetLogger(ctx).Info("QueryLatestEventsAndState 777777")
	for _, event := range stateEvents {
		response.StateEvents = append(response.StateEvents, event.Headered(roomInfo.RoomVersion))
	}

	return nil
}