services

type Attachment struct {
	AttachmentId string `json:"attachment_id"`
}

type BlazeMessage struct {
	Id     string                 `json:"id"`
	Action string                 `json:"action"`
	Params map[string]interface{} `json:"params,omitempty"`
	Data   interface{}            `json:"data,omitempty"`
	Error  *session.Error         `json:"error,omitempty"`
}

type Event struct {
	// contains filtered or unexported fields
}

type EventFactory struct {
	// contains filtered or unexported fields
}

type Hub struct {
	// contains filtered or unexported fields
}

type MessageContext struct {
	Transactions   *tmap
	ReadDone       chan bool
	WriteDone      chan bool
	DistributeDone chan bool
	ReadBuffer     chan MessageView
	WriteBuffer    chan []byte
	RecipientId    map[string]time.Time
}

type MessageService struct{}

type MessageView struct {
	ConversationId string    `json:"conversation_id"`
	UserId         string    `json:"user_id"`
	MessageId      string    `json:"message_id"`
	QuoteMessageId string    `json:"quote_message_id"`
	Category       string    `json:"category"`
	Data           string    `json:"data"`
	Status         string    `json:"status"`
	Source         string    `json:"source"`
	CreatedAt      time.Time `json:"created_at"`
	UpdatedAt      time.Time `json:"updated_at"`
}

type Service interface {
	Run(context.Context) error
}

type TransferView struct {
	Type          string    `json:"type"`
	SnapshotId    string    `json:"snapshot_id"`
	CounterUserId string    `json:"counter_user_id"`
	AssetId       string    `json:"asset_id"`
	Amount        string    `json:"amount"`
	TraceId       string    `json:"trace_id"`
	Memo          string    `json:"memo"`
	CreatedAt     time.Time `json:"created_at"`
}

type WxPaymentService struct{}