tasks

Documentation

Index

• Constants
• Variables
• func CollectChat(taskCtx plugin.SubTaskContext) errors.Error
• func CollectMeetingTopUserItem(taskCtx plugin.SubTaskContext) errors.Error
• func CollectMessage(taskCtx plugin.SubTaskContext) errors.Error
• func ExtractChatItem(taskCtx plugin.SubTaskContext) errors.Error
• func ExtractMeetingTopUserItem(taskCtx plugin.SubTaskContext) errors.Error
• func ExtractMessage(taskCtx plugin.SubTaskContext) errors.Error
• func NewFeishuApiClient(taskCtx plugin.TaskContext, connection *models.FeishuConnection) (*api.ApiAsyncClient, errors.Error)
• type ChatInput
• type FeishuApiParams
• type FeishuOptions
• type FeishuTaskData

Constants

const RAW_CHAT_TABLE = "feishu_chat_item"

const RAW_MEETING_TOP_USER_ITEM_TABLE = "feishu_meeting_top_user_item"

const RAW_MESSAGE_TABLE = "feishu_message"

Variables

var CollectChatMeta = plugin.SubTaskMeta{
	Name:             "collectChat",
	EntryPoint:       CollectChat,
	EnabledByDefault: true,
	Description:      "Collect chats from Feishu api",
}

var CollectMeetingTopUserItemMeta = plugin.SubTaskMeta{
	Name:             "collectMeetingTopUserItem",
	EntryPoint:       CollectMeetingTopUserItem,
	EnabledByDefault: true,
	Description:      "Collect top user meeting data from Feishu api",
}

var CollectMessageMeta = plugin.SubTaskMeta{
	Name:             "collectMeesage",
	EntryPoint:       CollectMessage,
	EnabledByDefault: true,
	Description:      "Collect message from Feishu api",
}

var ExtractChatItemMeta = plugin.SubTaskMeta{
	Name:             "extractChatItem",
	EntryPoint:       ExtractChatItem,
	EnabledByDefault: true,
	Description:      "Extract raw chats data into tool layer table feishu_meeting_top_user_item",
}

var ExtractMeetingTopUserItemMeta = plugin.SubTaskMeta{
	Name:             "extractMeetingTopUserItem",
	EntryPoint:       ExtractMeetingTopUserItem,
	EnabledByDefault: true,
	Description:      "Extract raw top user meeting data into tool layer table feishu_meeting_top_user_item",
}

var ExtractMessageMeta = plugin.SubTaskMeta{
	Name:             "extractChatItem",
	EntryPoint:       ExtractMessage,
	EnabledByDefault: true,
	Description:      "Extract raw messages data into tool layer table feishu_meeting_top_user_item",
}

Functions

func CollectChat

func CollectChat(taskCtx plugin.SubTaskContext) errors.Error

CollectChat collect all chats that bot is in

func CollectMeetingTopUserItem

func CollectMeetingTopUserItem(taskCtx plugin.SubTaskContext) errors.Error

func CollectMessage

func CollectMessage(taskCtx plugin.SubTaskContext) errors.Error

func ExtractChatItem

func ExtractChatItem(taskCtx plugin.SubTaskContext) errors.Error

func ExtractMeetingTopUserItem

func ExtractMeetingTopUserItem(taskCtx plugin.SubTaskContext) errors.Error

func ExtractMessage

func ExtractMessage(taskCtx plugin.SubTaskContext) errors.Error

func NewFeishuApiClient

func NewFeishuApiClient(taskCtx plugin.TaskContext, connection *models.FeishuConnection) (*api.ApiAsyncClient, errors.Error)

Types

type ChatInput

type ChatInput struct {
	ChatId string `json:"chat_id"`
}

type FeishuApiParams

type FeishuApiParams struct {
	ConnectionId uint64 `json:"connectionId"`
}

type FeishuOptions

type FeishuOptions struct {
	ConnectionId       uint64  `json:"connectionId"`
	NumOfDaysToCollect float64 `json:"numOfDaysToCollect"`
}

type FeishuTaskData

type FeishuTaskData struct {
	Options   *FeishuOptions
	ApiClient *helper.ApiAsyncClient
}