Commit f0ead1c5 authored by Fernando Takagi's avatar Fernando Takagi
Browse files

Add to api client

parent df30ba73
Loading
Loading
Loading
Loading
+8 −0
Original line number Diff line number Diff line
@@ -1319,6 +1319,14 @@
            "in": "query",
            "required": false,
            "type": "string"
          },
          {
            "name": "instant",
            "description": "Time which around to list messages in seconds (since epoch), if any. Used only if no cursor is provided.",
            "in": "query",
            "required": false,
            "type": "string",
            "format": "int64"
          }
        ],
        "tags": [
+6 −1
Original line number Diff line number Diff line
@@ -68,12 +68,17 @@ func (s *ApiServer) ListChannelMessages(ctx context.Context, in *api.ListChannel
		forward = in.GetForward().Value
	}

	var instant int64
	if in.GetInstant() != nil {
		instant = in.GetInstant().Value
	}

	streamConversionResult, err := ChannelIdToStream(in.ChannelId)
	if err != nil {
		return nil, status.Error(codes.InvalidArgument, "Invalid channel ID.")
	}

	messageList, err := ChannelMessagesList(ctx, s.logger, s.db, userID, streamConversionResult.Stream, in.ChannelId, limit, forward, in.Cursor, nil)
	messageList, err := ChannelMessagesList(ctx, s.logger, s.db, userID, streamConversionResult.Stream, in.ChannelId, limit, forward, in.Cursor, instant)
	if err == runtime.ErrChannelCursorInvalid {
		return nil, status.Error(codes.InvalidArgument, "Cursor is invalid or expired.")
	} else if err == runtime.ErrChannelGroupNotFound {