Struct Line

pub struct Line {
    pub config: LineConfig,
    client: Client,
    pub image_buffer: HashMap<String, Vec<InputContent>>,
    pub chat_history: Option<ChatHistory>,
    pub history_timeout: Option<Instant>,
    pub func_table: Option<FunctionTable<FunctionContext>>,
}

LINE システムモジュール。

Option は遅延初期化。

Fields

config: LineConfig

設定データ。

client: Client

HTTP クライアント。

image_buffer: HashMap<String, Vec<InputContent>>

chat_history: Option<ChatHistory>

ai コマンドの会話履歴。

history_timeout: Option<Instant>

Self::image_buffer Self::chat_history の有効期限。

func_table: Option<FunctionTable<FunctionContext>>

OpenAI function 機能テーブル

Implementations

impl Line

pub fn new() -> Result<Self>

コンストラクタ。

async fn init_openai(&mut self, ctrl: &Control)

pub async fn chat_history(&mut self, ctrl: &Control) -> &ChatHistory

pub async fn chat_history_mut(&mut self, ctrl: &Control) -> &mut ChatHistory

pub async fn func_table( &mut self, ctrl: &Control, ) -> &FunctionTable<FunctionContext>

impl Line

pub async fn get_profile(&self, user_id: &str) -> Result<ProfileResp>

pub async fn get_group_profile( &self, group_id: &str, user_id: &str, ) -> Result<ProfileResp>

pub async fn get_content(&self, message_id: &str) -> Result<Vec<u8>>

コンテンツを取得する。

https://developers.line.biz/ja/reference/messaging-api/#get-content

Webhookで受信したメッセージIDを使って、ユーザーが送信した画像、動画、音声、 およびファイルを取得するエンドポイントです。 このエンドポイントは、Webhookイベントオブジェクトの contentProvider.typeプロパティがlineの場合にのみ利用できます。 ユーザーからデータサイズが大きい動画または音声が送られた場合に、 コンテンツのバイナリデータを取得できるようになるまで時間がかかるときがあります。 バイナリデータの準備中にコンテンツを取得しようとすると、 ステータスコード202が返されバイナリデータは取得できません。 バイナリデータが取得できるかどうかは、 動画または音声の取得準備の状況を確認するエンドポイントで確認できます。 なお、ユーザーが送信したコンテンツは、 縮小などの変換が内部的に行われる場合があります。

pub fn postpone_timeout(&mut self)

pub async fn check_history_timeout(&mut self, ctrl: &Control)

Self::image_buffer Self::chat_history にタイムアウトを適用する。

pub async fn reply(&self, reply_token: &str, text: &str) -> Result<ReplyResp>

Self::reply_multi のシンプル版。 文字列が長すぎるならば分割して送信する。

pub async fn reply_multi( &self, reply_token: &str, texts: &[&str], ) -> Result<ReplyResp>

https://developers.line.biz/ja/reference/messaging-api/#send-reply-message

https://developers.line.biz/ja/docs/messaging-api/text-character-count/

texts のそれぞれについて、長すぎるならば分割し、 文字列メッセージ配列として送信する。 配列の最大サイズは 5。

pub async fn push_message(&self, to: &str, text: &str) -> Result<ReplyResp>

https://developers.line.biz/ja/reference/messaging-api/#send-push-message

https://developers.line.biz/ja/docs/messaging-api/text-character-count/

pub async fn push_image_message(&self, to: &str, url: &str) -> Result<ReplyResp>

https://developers.line.biz/ja/reference/messaging-api/#send-push-message

async fn check_resp_json<'a, T>(resp: Response) -> Result<T>

where T: for<'de> Deserialize<'de>,

レスポンスの内容を確認しながら json に変換する。

• HTTP Status が成功の場合
  • Response body JSON を T に変換できればそれを返す。
  • 変換に失敗したらエラー。
• HTTP Status が失敗の場合
  • Response body JSON を ErrorResp にパースできればその Debug を メッセージとしてエラーを返す。
  • 変換に失敗した場合、JSON ソースをメッセージとしてエラーを返す。

async fn get_auth_json<'a, T>(&self, url: &str) -> Result<T>

where T: for<'de> Deserialize<'de>,

async fn post_auth_json<T, R>(&self, url: &str, body: &T) -> Result<R>

where T: Serialize + Debug, R: for<'de> Deserialize<'de>,

async fn get_auth_bin(&self, url: &str) -> Result<(StatusCode, Vec<u8>)>

Trait Implementations

impl SystemModule for Line

fn on_start(&mut self, _ctrl: &Control)

SystemModule の初期化時には [crate::sys::taskserver::TaskServer] がまだ存在しないので タスクの登録はこのタイミングまで遅延させる。