teidesu/mtcute
1
0
Fork 0
Code Issues 15 Pull requests 1 Projects Releases Packages Wiki Activity Actions

refactor(client): extract message action to separate type and file

Browse source
This commit is contained in:
teidesu 2021-05-10 16:36:16 +03:00
parent e28ec79110
commit fe0f0849a4
2 changed files with 440 additions and 459 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

436
packages/client/src/types/messages/message-action.ts Normal file
View file

@ -0,0 +1,436 @@
import { tl } from '@mtcute/tl'
import { Photo } from '../media'
import { _callDiscardReasonFromTl, CallDiscardReason } from '../calls/discard-reason'
export namespace MessageAction {
/** Group was created */
export interface ActionChatCreated {
readonly type: 'chat_created'
/** Group name */
readonly title: string
/** IDs of the users in the group */
readonly users: number[]
}
/** Channel/supergroup was created */
export interface ActionChannelCreated {
readonly type: 'channel_created'
/** Original channel/supergroup title */
readonly title: string
}
/** Chat was migrated to a supergroup with a given ID */
export interface ActionChatMigrateTo {
readonly type: 'chat_migrate_to'
/** Marked ID of the supergroup chat was migrated to */
readonly id: number
}
/** Supergroup was migrated from a chat with a given ID */
export interface ActionChannelMigrateFrom {
readonly type: 'channel_migrate_from'
/** Marked ID of the chat this channel was migrated from */
readonly id: number
/** Old chat's title */
readonly title: string
}
/**
* A message has been pinned.
*
* To get the message itself, use {@link Message.getReplyTo}
*/
export interface ActionMessagePinned {
readonly type: 'message_pinned'
}
/** History was cleared in a private chat. */
export interface ActionHistoryCleared {
readonly type: 'history_cleared'
}
/** Someone scored in a game (usually only used for newly set high scores) */
export interface ActionGameScore {
readonly type: 'game_score'
/** Game ID */
readonly gameId: tl.Long
/** Score */
readonly score: number
}
/** Contact has joined Telegram */
export interface ActionContactJoined {
readonly type: 'contact_joined'
}
/** Group title was changed */
export interface ActionTitleChanged {
readonly type: 'title_changed'
/** New group name */
readonly title: string
}
/** Group photo was changed */
export interface ActionPhotoChanged {
readonly type: 'photo_changed'
/** New group photo */
readonly photo: Photo
}
/** Group photo was deleted */
export interface ActionPhotoDeleted {
readonly type: 'photo_deleted'
}
/** Users were added to the chat */
export interface ActionUsersAdded {
readonly type: 'users_added'
/** IDs of the users that were added */
readonly users: number[]
}
/** User has left the group */
export interface ActionUserLeft {
readonly type: 'user_left'
}
/** User was removed from the group */
export interface ActionUserRemoved {
readonly type: 'user_removed'
/** ID of the user that was removed from the group */
readonly user: number
}
/** User has joined the group via an invite link */
export interface ActionUserJoinedLink {
readonly type: 'user_joined_link'
/** ID of the user who created the link */
readonly inviter: number
}
/** A payment was received from a user (bot) */
export interface ActionPaymentReceived {
readonly type: 'payment_received'
/** Three-letter ISO 4217 currency code */
readonly currency: string
/**
* Price of the product in the smallest units of the currency
* (integer, not float/double). For example, for a price of
* `US$ 1.45`, `amount = 145`
*/
readonly amount: tl.Long
/** Bot specified invoice payload */
readonly payload: Buffer
/** Order information provided by the user */
readonly info?: tl.TypePaymentRequestedInfo
/** ID of the shipping option chosen by the user */
readonly shippingOptionId?: string
/** Payment provider ID */
readonly charge?: tl.TypePaymentCharge
}
/** A payment was sent to a user */
export interface ActionPaymentSent {
readonly type: 'payment_sent'
/** Three-letter ISO 4217 currency code */
readonly currency: string
/**
* Price of the product in the smallest units of the currency
* (integer, not float/double). For example, for a price of
* `US$ 1.45`, `amount = 145`
*/
readonly amount: tl.Long
}
/** A phone call */
export interface ActionCall {
readonly type: 'call'
/** Call ID */
readonly id: tl.Long
/** Whether this is a video call */
readonly isVideo: boolean
/** Duration if the call in seconds (0 if not available) */
readonly duration: number
/** Call discard reason, if available */
readonly reason?: CallDiscardReason
}
/** A screenshot was taken */
export interface ActionScreenshotTaken {
readonly type: 'screenshot_taken'
}
/** User has authorized via the bot */
export interface ActionBotAllowed {
readonly type: 'bot_allowed'
/** Domain where the user has logged in */
readonly domain: string
}
/**
* A user is in proximity of another user
* (see [Proximity alerts]{https://core.telegram.org/api/live-location#proximity-alert})
*/
export interface ActionGeoProximity {
readonly type: 'geo_proximity'
/** ID of the user who sent the geolocation with proximity alerts */
readonly targetId: number
/** ID of the user who has approached `targetId` */
readonly userId: number
/** Distance between them in meters */
readonly distance: number
}
/** Group call has started */
export interface ActionGroupCallStarted {
readonly type: 'group_call_started'
/** TL object representing the call */
readonly call: tl.TypeInputGroupCall
}
/** Group call has ended */
export interface ActionGroupCallEnded {
readonly type: 'group_call_ended'
/** TL object representing the call */
readonly call: tl.TypeInputGroupCall
/** Duration of the call */
readonly duration: number
}
/** Group call has ended */
export interface ActionGroupInvite {
readonly type: 'group_call_invite'
/** TL object representing the call */
readonly call: tl.TypeInputGroupCall
/** IDs of the users invited to the call */
readonly userIds: number[]
}
/** Messages TTL changed */
export interface ActionSetTtl {
readonly type: 'set_ttl'
/** New TTL period */
readonly period: number
}
}
export type MessageAction =
| MessageAction.ActionChatCreated
| MessageAction.ActionChannelCreated
| MessageAction.ActionChatMigrateTo
| MessageAction.ActionChannelMigrateFrom
| MessageAction.ActionMessagePinned
| MessageAction.ActionHistoryCleared
| MessageAction.ActionGameScore
| MessageAction.ActionContactJoined
| MessageAction.ActionTitleChanged
| MessageAction.ActionPhotoChanged
| MessageAction.ActionPhotoDeleted
| MessageAction.ActionUsersAdded
| MessageAction.ActionUserLeft
| MessageAction.ActionUserRemoved
| MessageAction.ActionUserJoinedLink
| MessageAction.ActionPaymentReceived
| MessageAction.ActionPaymentSent
| MessageAction.ActionCall
| MessageAction.ActionScreenshotTaken
| MessageAction.ActionBotAllowed
| MessageAction.ActionGeoProximity
| MessageAction.ActionGroupCallStarted
| MessageAction.ActionGroupCallEnded
| MessageAction.ActionGroupInvite
| MessageAction.ActionSetTtl
| null
export function _messageActionFromTl(act: tl.TypeMessageAction): MessageAction {
switch (act._) {
case 'messageActionChatCreate':
return {
type: 'chat_created',
title: act.title,
users: act.users,
}
case 'messageActionChannelCreate':
return {
type: 'channel_created',
title: act.title,
}
case 'messageActionChatMigrateTo':
return {
type: 'chat_migrate_to',
id: act.channelId,
}
case 'messageActionChannelMigrateFrom':
return {
type: 'channel_migrate_from',
id: act.chatId,
title: act.title,
}
case 'messageActionPinMessage':
return {
type: 'message_pinned',
}
case 'messageActionHistoryClear':
return {
type: 'history_cleared',
}
case 'messageActionGameScore':
return {
type: 'game_score',
gameId: act.gameId,
score: act.score,
}
case 'messageActionContactSignUp':
return {
type: 'contact_joined',
}
case 'messageActionChatEditTitle':
return {
type: 'title_changed',
title: act.title,
}
case 'messageActionChatEditPhoto':
return {
type: 'photo_changed',
photo: new Photo(
this.client,
act.photo as tl.RawPhoto
),
}
case 'messageActionChatDeletePhoto':
return {
type: 'photo_deleted',
}
case 'messageActionChatAddUser':
return {
type: 'users_added',
users: act.users,
}
case 'messageActionChatDeleteUser':
if (
this.raw.fromId?._ === 'peerUser' &&
act.userId === this.raw.fromId.userId
) {
return {
type: 'user_left',
}
} else {
return {
type: 'user_removed',
user: act.userId,
}
}
case 'messageActionChatJoinedByLink':
return {
type: 'user_joined_link',
inviter: act.inviterId,
}
case 'messageActionPaymentSentMe':
return {
type: 'payment_received',
currency: act.currency,
amount: act.totalAmount,
payload: act.payload,
info: act.info,
shippingOptionId: act.shippingOptionId,
charge: act.charge,
}
case 'messageActionPaymentSent':
return {
type: 'payment_sent',
currency: act.currency,
amount: act.totalAmount,
}
case 'messageActionPhoneCall':
return {
type: 'call',
id: act.callId,
isVideo: !!act.video,
reason: act.reason
? _callDiscardReasonFromTl(act.reason)
: undefined,
duration: act.duration ?? 0,
}
case 'messageActionScreenshotTaken':
return {
type: 'screenshot_taken'
}
case 'messageActionBotAllowed':
return {
type: 'bot_allowed',
domain: act.domain
}
case 'messageActionGeoProximityReached':
if (act.fromId._ !== 'peerUser' || act.toId._ !== 'peerUser') {
return null
} else {
return {
type: 'geo_proximity',
targetId: act.toId.userId,
userId: act.fromId.userId,
distance: act.distance
}
}
case 'messageActionGroupCall':
if (act.duration) {
return {
type: 'group_call_ended',
call: act.call,
duration: act.duration
}
} else {
return {
type: 'group_call_started',
call: act.call
}
}
case 'messageActionInviteToGroupCall':
return {
type: 'group_call_invite',
call: act.call,
userIds: act.users
}
case 'messageActionSetMessagesTTL':
return {
type: 'set_ttl',
period: act.period
}
default:
return null
}
}

463
packages/client/src/types/messages/message.ts
View file

@ -33,256 +33,12 @@ import {
_callDiscardReasonFromTl, _callDiscardReasonFromTl,
CallDiscardReason, CallDiscardReason,
} from '../calls/discard-reason' } from '../calls/discard-reason'
import { _messageActionFromTl, MessageAction } from './message-action'
/** /**
* A message or a service message * A message or a service message
*/ */
export namespace Message { export namespace Message {
/** Group was created */
export interface ActionChatCreated {
readonly type: 'chat_created'
/** Group name */
readonly title: string
/** IDs of the users in the group */
readonly users: number[]
}
/** Channel/supergroup was created */
export interface ActionChannelCreated {
readonly type: 'channel_created'
/** Original channel/supergroup title */
readonly title: string
}
/** Chat was migrated to a supergroup with a given ID */
export interface ActionChatMigrateTo {
readonly type: 'chat_migrate_to'
/** Marked ID of the supergroup chat was migrated to */
readonly id: number
}
/** Supergroup was migrated from a chat with a given ID */
export interface ActionChannelMigrateFrom {
readonly type: 'channel_migrate_from'
/** Marked ID of the chat this channel was migrated from */
readonly id: number
/** Old chat's title */
readonly title: string
}
/**
* A message has been pinned.
*
* To get the message itself, use {@link Message.getReplyTo}
*/
export interface ActionMessagePinned {
readonly type: 'message_pinned'
}
/** History was cleared in a private chat. */
export interface ActionHistoryCleared {
readonly type: 'history_cleared'
}
/** Someone scored in a game (usually only used for newly set high scores) */
export interface ActionGameScore {
readonly type: 'game_score'
/** Game ID */
readonly gameId: tl.Long
/** Score */
readonly score: number
}
/** Contact has joined Telegram */
export interface ActionContactJoined {
readonly type: 'contact_joined'
}
/** Group title was changed */
export interface ActionTitleChanged {
readonly type: 'title_changed'
/** New group name */
readonly title: string
}
/** Group photo was changed */
export interface ActionPhotoChanged {
readonly type: 'photo_changed'
/** New group photo */
readonly photo: Photo
}
/** Group photo was deleted */
export interface ActionPhotoDeleted {
readonly type: 'photo_deleted'
}
/** Users were added to the chat */
export interface ActionUsersAdded {
readonly type: 'users_added'
/** IDs of the users that were added */
readonly users: number[]
}
/** User has left the group */
export interface ActionUserLeft {
readonly type: 'user_left'
}
/** User was removed from the group */
export interface ActionUserRemoved {
readonly type: 'user_removed'
/** ID of the user that was removed from the group */
readonly user: number
}
/** User has joined the group via an invite link */
export interface ActionUserJoinedLink {
readonly type: 'user_joined_link'
/** ID of the user who created the link */
readonly inviter: number
}
/** A payment was received from a user (bot) */
export interface ActionPaymentReceived {
readonly type: 'payment_received'
/** Three-letter ISO 4217 currency code */
readonly currency: string
/**
* Price of the product in the smallest units of the currency
* (integer, not float/double). For example, for a price of
* `US$ 1.45`, `amount = 145`
*/
readonly amount: tl.Long
/** Bot specified invoice payload */
readonly payload: Buffer
/** Order information provided by the user */
readonly info?: tl.TypePaymentRequestedInfo
/** ID of the shipping option chosen by the user */
readonly shippingOptionId?: string
/** Payment provider ID */
readonly charge?: tl.TypePaymentCharge
}
/** A payment was sent to a user */
export interface ActionPaymentSent {
readonly type: 'payment_sent'
/** Three-letter ISO 4217 currency code */
readonly currency: string
/**
* Price of the product in the smallest units of the currency
* (integer, not float/double). For example, for a price of
* `US$ 1.45`, `amount = 145`
*/
readonly amount: tl.Long
}
/** A phone call */
export interface ActionCall {
readonly type: 'call'
/** Call ID */
readonly id: tl.Long
/** Whether this is a video call */
readonly isVideo: boolean
/** Duration if the call in seconds (0 if not available) */
readonly duration: number
/** Call discard reason, if available */
readonly reason?: CallDiscardReason
}
/** A screenshot was taken */
export interface ActionScreenshotTaken {
readonly type: 'screenshot_taken'
}
/** User has authorized via the bot */
export interface ActionBotAllowed {
readonly type: 'bot_allowed'
/** Domain where the user has logged in */
readonly domain: string
}
/**
* A user is in proximity of another user
* (see [Proximity alerts]{https://core.telegram.org/api/live-location#proximity-alert})
*/
export interface ActionGeoProximity {
readonly type: 'geo_proximity'
/** ID of the user who sent the geolocation with proximity alerts */
readonly targetId: number
/** ID of the user who has approached `targetId` */
readonly userId: number
/** Distance between them in meters */
readonly distance: number
}
/** Group call has started */
export interface ActionGroupCallStarted {
readonly type: 'group_call_started'
/** TL object representing the call */
readonly call: tl.TypeInputGroupCall
}
/** Group call has ended */
export interface ActionGroupCallEnded {
readonly type: 'group_call_ended'
/** TL object representing the call */
readonly call: tl.TypeInputGroupCall
/** Duration of the call */
readonly duration: number
}
/** Group call has ended */
export interface ActionGroupInvite {
readonly type: 'group_call_invite'
/** TL object representing the call */
readonly call: tl.TypeInputGroupCall
/** IDs of the users invited to the call */
readonly userIds: number[]
}
/** Messages TTL changed */
export interface ActionSetTtl {
readonly type: 'set_ttl'
/** New TTL period */
readonly period: number
}
/** Information about a forward */ /** Information about a forward */
export interface MessageForwardInfo { export interface MessageForwardInfo {
/** /**
@ -309,34 +65,6 @@ export namespace Message {
signature?: string signature?: string
} }
export type MessageAction =
| ActionChatCreated
| ActionChannelCreated
| ActionChatMigrateTo
| ActionChannelMigrateFrom
| ActionMessagePinned
| ActionHistoryCleared
| ActionGameScore
| ActionContactJoined
| ActionTitleChanged
| ActionPhotoChanged
| ActionPhotoDeleted
| ActionUsersAdded
| ActionUserLeft
| ActionUserRemoved
| ActionUserJoinedLink
| ActionPaymentReceived
| ActionPaymentSent
| ActionCall
| ActionScreenshotTaken
| ActionBotAllowed
| ActionGeoProximity
| ActionGroupCallStarted
| ActionGroupCallEnded
| ActionGroupInvite
| ActionSetTtl
| null
// todo: venue, poll, invoice, successful_payment, // todo: venue, poll, invoice, successful_payment,
// connected_website // connected_website
export type MessageMedia = export type MessageMedia =
@ -662,202 +390,19 @@ export class Message {
return this._entities return this._entities
} }
private _action?: Message.MessageAction private _action?: MessageAction
/** /**
* Message action. `null` for non-service messages * Message action. `null` for non-service messages
* or for unsupported events. * or for unsupported events.
* *
* For unsupported events, use `.raw.action` directly. * For unsupported events, use `.raw.action` directly.
*/ */
get action(): Message.MessageAction { get action(): MessageAction {
if (!this._action) { if (!this._action) {
if (this.raw._ === 'message') { if (this.raw._ === 'message') {
this._action = null this._action = null
} else { } else {
const act = this.raw.action this._action = _messageActionFromTl(this.raw.action)
let action: Message.MessageAction
switch (act._) {
case 'messageActionChatCreate':
action = {
type: 'chat_created',
title: act.title,
users: act.users,
}
break
case 'messageActionChannelCreate':
action = {
type: 'channel_created',
title: act.title,
}
break
case 'messageActionChatMigrateTo':
action = {
type: 'chat_migrate_to',
id: act.channelId,
}
break
case 'messageActionChannelMigrateFrom':
action = {
type: 'channel_migrate_from',
id: act.chatId,
title: act.title,
}
break
case 'messageActionPinMessage':
action = {
type: 'message_pinned',
}
break
case 'messageActionHistoryClear':
action = {
type: 'history_cleared',
}
break
case 'messageActionGameScore':
action = {
type: 'game_score',
gameId: act.gameId,
score: act.score,
}
break
case 'messageActionContactSignUp':
action = {
type: 'contact_joined',
}
break
case 'messageActionChatEditTitle':
action = {
type: 'title_changed',
title: act.title,
}
break
case 'messageActionChatEditPhoto':
action = {
type: 'photo_changed',
photo: new Photo(
this.client,
act.photo as tl.RawPhoto
),
}
break
case 'messageActionChatDeletePhoto':
action = {
type: 'photo_deleted',
}
break
case 'messageActionChatAddUser':
action = {
type: 'users_added',
users: act.users,
}
break
case 'messageActionChatDeleteUser':
if (
this.raw.fromId?._ === 'peerUser' &&
act.userId === this.raw.fromId.userId
) {
action = {
type: 'user_left',
}
} else {
action = {
type: 'user_removed',
user: act.userId,
}
}
break
case 'messageActionChatJoinedByLink':
action = {
type: 'user_joined_link',
inviter: act.inviterId,
}
break
case 'messageActionPaymentSentMe':
action = {
type: 'payment_received',
currency: act.currency,
amount: act.totalAmount,
payload: act.payload,
info: act.info,
shippingOptionId: act.shippingOptionId,
charge: act.charge,
}
break
case 'messageActionPaymentSent':
action = {
type: 'payment_sent',
currency: act.currency,
amount: act.totalAmount,
}
break
case 'messageActionPhoneCall':
action = {
type: 'call',
id: act.callId,
isVideo: !!act.video,
reason: act.reason
? _callDiscardReasonFromTl(act.reason)
: undefined,
duration: act.duration ?? 0,
}
break
case 'messageActionScreenshotTaken':
action = {
type: 'screenshot_taken'
}
break
case 'messageActionBotAllowed':
action = {
type: 'bot_allowed',
domain: act.domain
}
break
case 'messageActionGeoProximityReached':
if (act.fromId._ !== 'peerUser' || act.toId._ !== 'peerUser') {
action = null
} else {
action = {
type: 'geo_proximity',
targetId: act.toId.userId,
userId: act.fromId.userId,
distance: act.distance
}
}
break
case 'messageActionGroupCall':
if (act.duration) {
action = {
type: 'group_call_ended',
call: act.call,
duration: act.duration
}
} else {
action = {
type: 'group_call_started',
call: act.call
}
}
break
case 'messageActionInviteToGroupCall':
action = {
type: 'group_call_invite',
call: act.call,
userIds: act.users
}
break
case 'messageActionSetMessagesTTL':
action = {
type: 'set_ttl',
period: act.period
}
break
default:
action = null
break
}
this._action = action
} }
} }