API の使い方

import (
    "context"
    "crypto/tls"
    "log"
    "os"

    "github.com/mixigroup/mixi2-application-sdk-go/auth"
    application_apiv1 "github.com/mixigroup/mixi2-application-sdk-go/gen/go/social/mixi/application/api/v1"
    "google.golang.org/grpc"
    "google.golang.org/grpc/credentials"
)

// 認証の設定
authenticator, err := auth.NewAuthenticator(
    os.Getenv("CLIENT_ID"),
    os.Getenv("CLIENT_SECRET"),
    os.Getenv("TOKEN_URL"),
)
if err != nil {
    log.Fatal(err)
}

// API サーバーへの接続
apiConn, err := grpc.NewClient(
    os.Getenv("API_ADDRESS"),
    grpc.WithTransportCredentials(credentials.NewTLS(&tls.Config{})),
)
if err != nil {
    log.Fatal(err)
}
defer apiConn.Close()

// API クライアントの作成
client := application_apiv1.NewApplicationServiceClient(apiConn)

// 認証済みコンテキストの取得
authCtx, err := authenticator.AuthorizedContext(context.Background())
if err != nil {
    log.Fatal(err)
}

_, err := client.CreatePost(authCtx, &application_apiv1.CreatePostRequest{
    Text: "こんにちは！",
})
if err != nil {
    log.Fatal(err)
}

inReplyToPostId := event.Post.PostId
_, err := client.CreatePost(authCtx, &application_apiv1.CreatePostRequest{
    Text:         "これは面白い投稿ですね！",
    InReplyToPostId: &inReplyToPostId,
})
if err != nil {
    log.Fatal(err)
}

quotedPostId := originalPostId
_, err := client.CreatePost(authCtx, &application_apiv1.CreatePostRequest{
    Text:         "これは面白い投稿ですね！",
    QuotedPostId: &quotedPostId,
})
if err != nil {
    log.Fatal(err)
}

caption := "映画のネタバレ注意"
_, err := client.CreatePost(authCtx, &application_apiv1.CreatePostRequest{
    Text: "ネタバレを含む内容です...",
    PostMask: &modelv1.PostMask{
        MaskType: constv1.PostMaskType_POST_MASK_TYPE_SPOILER,
        Caption:  &caption,
    },
})
if err != nil {
    log.Fatal(err)
}

publishingType := constv1.PostPublishingType_POST_PUBLISHING_TYPE_NOT_PUBLISHING
_, err := client.CreatePost(authCtx, &application_apiv1.CreatePostRequest{
    Text:           "このポストはプロフィールにのみ表示されます",
    PublishingType: &publishingType,
})
if err != nil {
    log.Fatal(err)
}

// 作成したポストのIDを使用
createResp, err := client.CreatePost(authCtx, &application_apiv1.CreatePostRequest{
    Text: "テスト投稿",
})
if err != nil {
    log.Fatal(err)
}

// ポストを削除
_, err = client.DeletePost(authCtx, &application_apiv1.DeletePostRequest{
    PostId: createResp.Post.PostId,
})
if err != nil {
    log.Fatal(err)
}

text := "メッセージを受け取りました！"
_, err := client.SendChatMessage(authCtx, &application_apiv1.SendChatMessageRequest{
    RoomId: event.Message.RoomId,
    Text:   &text,
})
if err != nil {
    log.Fatal(err)
}

// メディアデータを準備（例: ファイルから読み込み）
imageData, err := os.ReadFile("image.jpg")
if err != nil {
    log.Fatal(err)
}

description := "画像の説明（任意）"
resp, err := client.InitiatePostMediaUpload(authCtx, &application_apiv1.InitiatePostMediaUploadRequest{
    MediaType:   application_apiv1.InitiatePostMediaUploadRequest_TYPE_IMAGE,
    ContentType: "image/jpeg",
    DataSize:    uint64(len(imageData)),
    Description: &description,
})
if err != nil {
    log.Fatal(err)
}

mediaId := resp.MediaId
uploadUrl := resp.UploadUrl

// アクセストークンを取得
accessToken, err := authenticator.GetAccessToken(authCtx)
if err != nil {
    log.Fatal(err)
}

// アップロードリクエストを作成
uploadReq, err := http.NewRequest(http.MethodPost, uploadUrl, bytes.NewReader(imageData))
if err != nil {
    log.Fatal(err)
}

uploadReq.Header.Set("Authorization", "Bearer "+accessToken)
uploadReq.Header.Set("Content-Type", "application/octet-stream")

// タイムアウト付きでアップロードを実行
httpClient := &http.Client{
    Timeout: 30 * time.Second,
}
uploadResp, err := httpClient.Do(uploadReq)
if err != nil {
    log.Fatal(err)
}
defer uploadResp.Body.Close()

// レスポンスステータスを確認
if uploadResp.StatusCode != http.StatusOK && uploadResp.StatusCode != http.StatusAccepted {
    respBody, _ := io.ReadAll(uploadResp.Body)
    log.Fatalf("media upload failed with status %s: %s", uploadResp.Status, string(respBody))
}

pollCtx, cancel := context.WithTimeout(authCtx, 2*time.Minute)
defer cancel()

ticker := time.NewTicker(5 * time.Second)
defer ticker.Stop()

pollLoop:
for {
    select {
    case <-pollCtx.Done():
        log.Fatalf("timed out waiting for media processing: %v", pollCtx.Err())
    case <-ticker.C:
        statusResp, err := client.GetPostMediaStatus(pollCtx, &application_apiv1.GetPostMediaStatusRequest{
            MediaId: mediaId,
        })
        if err != nil {
            log.Fatal(err)
        }

        if statusResp.Status == application_apiv1.GetPostMediaStatusResponse_STATUS_COMPLETED {
            break pollLoop
        }
        if statusResp.Status == application_apiv1.GetPostMediaStatusResponse_STATUS_FAILED {
            log.Fatal("media processing failed")
        }
    }
}

_, err := client.CreatePost(authCtx, &application_apiv1.CreatePostRequest{
    Text:        "画像を添付しました！",
    MediaIdList: []string{mediaId},
})
if err != nil {
    log.Fatal(err)
}

// 利用可能なスタンプ一覧を取得
language := constv1.LanguageCode_LANGUAGE_CODE_JP
stampsResp, err := client.GetStamps(authCtx, &application_apiv1.GetStampsRequest{
    OfficialStampLanguage: &language,
})
if err != nil {
    log.Fatal(err)
}

// スタンプを付与
_, err = client.AddStampToPost(authCtx, &application_apiv1.AddStampToPostRequest{
    PostId:  postId,
    StampId: stampsResp.OfficialStampSets[0].Stamps[0].StampId,
})
if err != nil {
    log.Fatal(err)
}

resp, err := client.GetUsers(authCtx, &application_apiv1.GetUsersRequest{
    UserIdList: []string{event.Post.CreatorId},
})
if err != nil {
    log.Fatal(err)
}

for _, user := range resp.Users {
    fmt.Printf("ユーザー名: %s\n", user.DisplayName)
}

resp, err := client.GetPosts(authCtx, &application_apiv1.GetPostsRequest{
    PostIdList: []string{event.Post.GetInReplyToPostId()},
})
if err != nil {
    log.Fatal(err)
}

for _, post := range resp.Posts {
    fmt.Printf("ポスト本文: %s\n", post.Text)
}