Go SDK：KYC・AML・取引モニタリング向け

GoのためのDidit公式モジュールです。Go 1.22以降が必要で、標準ライブラリのみを使用します。すべてのSDKに共通する内容は、サーバーSDKの概要を参照してください。

インストール

go get github.com/didit-protocol/sdk-go

モジュールはpkg.go.devのgithub.com/didit-protocol/sdk-goです。ソースコードと変更履歴はGitHubのdidit-protocol/sdk-goにあります。パッケージ名はdiditです。Webhookはgithub.com/didit-protocol/sdk-go/webhookに、Authenticationは.../authenticationに、クライアントオプションは.../optionにあります。各APIリファレンスページのサンプルは関数の本体です。標準ライブラリのcontext、fmt、logと、このモジュールを使用しています。

クライアントを設定する

didit.NewClient()は環境変数からDIDIT_API_KEYを読み込みます。これを上書きする場合や、アプリケーションスコープの呼び出し(ケース、ネットワーク、規制レポート)に必要な組織IDとアプリケーションIDを設定する場合は、オプションを渡します。どのオプションも、個々の呼び出しに対して指定することもできます。

package main

import (
	"context"
	"fmt"
	"log"
	"os"
	"time"

	"github.com/didit-protocol/sdk-go"
	"github.com/didit-protocol/sdk-go/option"
)

func main() {
	client := didit.NewClient(
		option.WithAPIKey(os.Getenv("DIDIT_API_KEY")),
		option.WithOrganizationID(os.Getenv("DIDIT_ORGANIZATION_ID")),
		option.WithApplicationID(os.Getenv("DIDIT_APPLICATION_ID")),
		option.WithTimeout(30*time.Second),
		option.WithMaxRetries(2),
	)

	// Options for a single call.
	decision, err := client.Sessions.RetrieveDecision(context.Background(), "11111111-2222-3333-4444-555555555555",
		didit.SessionsRetrieveDecisionParams{}, option.WithTimeout(5*time.Second))
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println(decision.Status)
}

任意のリクエストフィールドはdidit.Opt値です。didit.String、didit.Int、didit.Bool、didit.Floatまたはdidit.Someで設定し、何も送信しない場合は省略します。

セッションを作成する

ワークフローの認証セッションを作成し、ユーザーをそのURLに誘導します。

package main

import (
	"context"
	"fmt"
	"log"

	"github.com/didit-protocol/sdk-go"
)

func main() {
	client := didit.NewClient()

	session, err := client.Sessions.Create(context.Background(), didit.SessionsCreateParams{
		WorkflowID: "11111111-2222-3333-4444-555555555555",
		VendorData: didit.String("user-123"),
		Callback:   didit.String("https://example.com/verification/done"),
	})
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println(session.URL)
}

判定を読み取る

ユーザーによる操作が完了したとき(またはWebhookが届いたとき)に、判定を読み取ります。各機能の結果はスライスで、ワークフローのノードごとに1つのエントリがあります。

package main

import (
	"context"
	"fmt"
	"log"

	"github.com/didit-protocol/sdk-go"
)

func main() {
	client := didit.NewClient()

	decision, err := client.Sessions.RetrieveDecision(context.Background(), "11111111-2222-3333-4444-555555555555",
		didit.SessionsRetrieveDecisionParams{})
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println(decision.Status)
	for _, verification := range decision.IDVerifications {
		fmt.Println(verification.Status)
	}
}

Webhookを検証する

生のボディのバイト列とリクエストヘッダーを渡します。webhook.Verifyは、有効かつ期限内の配信ではないすべてのものに対して*didit.WebhookVerificationErrorを返し、それ以外の場合は型付きのイベントを返します。

package main

import (
	"errors"
	"fmt"
	"io"
	"log"
	"net/http"
	"os"

	"github.com/didit-protocol/sdk-go"
	"github.com/didit-protocol/sdk-go/webhook"
)

func main() {
	secret := os.Getenv("DIDIT_WEBHOOK_SECRET")
	http.HandleFunc("POST /webhooks/didit", func(w http.ResponseWriter, r *http.Request) {
		body, err := io.ReadAll(http.MaxBytesReader(w, r.Body, 1<<20))
		if err != nil {
			http.Error(w, "bad body", http.StatusBadRequest)
			return
		}
		event, err := webhook.Verify(body, r.Header, secret)
		var invalid *didit.WebhookVerificationError
		if errors.As(err, &invalid) {
			http.Error(w, string(invalid.Reason), http.StatusBadRequest)
			return
		} else if err != nil {
			http.Error(w, "error", http.StatusInternalServerError)
			return
		}
		if e, ok := event.(*webhook.StatusUpdatedEvent); ok {
			fmt.Println(e.SessionID, e.Status)
		}
		w.WriteHeader(http.StatusOK)
	})
	log.Fatal(http.ListenAndServe(":8080", nil))
}

シークレットをローテーションしている間は、古いシークレットをwebhook.WithSecretsで追加します。イベントと署名方式についてはWebhookを参照してください。

取引をスクリーニングする

支払い、出金、暗号資産の送金をトランザクションモニタリングに送信します。レスポンスにはそのステータスとリスクスコアが含まれます。

package main

import (
	"context"
	"fmt"
	"log"

	"github.com/didit-protocol/sdk-go"
)

func main() {
	client := didit.NewClient()

	transaction, err := client.Transactions.Create(context.Background(), didit.TransactionsCreateParams{
		TransactionID:       "txn-1001",
		TransactionCategory: "finance",
		TransactionDetails: didit.TransactionsCreateParamsTransactionDetails{
			Direction: "outbound",
			Amount:    1500,
			Currency:  "EUR",
		},
		Subject: didit.TransactionsCreateParamsSubject{
			EntityType: didit.String("individual"),
			VendorData: "user-123",
			FullName:   "Maria Garcia",
		},
	})
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println(transaction.Status, transaction.Score)
}

Authenticationトークンを検証する

authenticationパッケージは、Authenticationの発行者が署名したアクセストークンを、リクエストごとにDiditを呼び出すことなくバックエンドで検証します。また、コードの交換、トークンの更新、セッションの確認と取り消し、ステップアップの実行も行います。

トークン検証では、アプリケーションの発行者と署名鍵に対して、サーバーでトークンを検証するに記載されたチェックを実行します。

package main

import (
	"context"
	"errors"
	"fmt"
	"log"

	"github.com/didit-protocol/sdk-go"
	"github.com/didit-protocol/sdk-go/authentication"
)

func main() {
	// The publishable key (pk_live_... or pk_test_...) carries your issuer URL.
	auth, err := authentication.NewFromPublishableKey("pk_live_...", authentication.WithClientID("your-application-id"))
	if err != nil {
		log.Fatal(err)
	}

	claims, err := auth.VerifyAccessToken(context.Background(), "the bearer token")
	var invalid *didit.TokenVerificationError
	if errors.As(err, &invalid) {
		fmt.Println("rejected:", invalid.Reason)
		return
	} else if err != nil {
		log.Fatal(err)
	}
	fmt.Println(claims.Subject)
}

エラー

package main

import (
	"context"
	"errors"
	"fmt"

	"github.com/didit-protocol/sdk-go"
)

func main() {
	client := didit.NewClient()

	_, err := client.Sessions.RetrieveDecision(context.Background(), "11111111-2222-3333-4444-555555555555",
		didit.SessionsRetrieveDecisionParams{})
	var notFound *didit.NotFoundError
	var status *didit.APIStatusError
	switch {
	case errors.As(err, &notFound):
		fmt.Println("no such session")
	case errors.As(err, &status):
		fmt.Println(status.StatusCode, status.RequestID, status.Body)
	case err != nil:
		fmt.Println("no response:", err)
	}
}

リストとファイル

package main

import (
	"context"
	"fmt"
	"log"

	"github.com/didit-protocol/sdk-go"
)

func main() {
	ctx := context.Background()
	client := didit.NewClient()

	// Lists page through every result.
	iter := client.Sessions.ListAutoPaging(ctx, didit.SessionsListParams{Status: didit.String("Approved")})
	for iter.Next() {
		fmt.Println(iter.Current().SessionID)
	}
	if err := iter.Err(); err != nil {
		log.Fatal(err)
	}

	// Uploads take didit.FileFromPath, FileFromBytes or FileFromReader.
	result, err := client.IDVerification.Verify(ctx, didit.IDVerificationVerifyParams{
		FrontImage: didit.FileFromPath("id-front.jpg"),
		BackImage:  didit.Some(didit.FileFromPath("id-back.jpg")),
	})
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println(result.IDVerification.Status)
}

Go SDKにまだないエンドポイント

Go 1.0.1は以下のエンドポイントがAPIに追加される前に生成されたため、これらに対応するメソッドはなく、各ページにもGoのサンプルはありません。

住所を検証する
取引を一括削除する
トラベルルールのネットワーク: ネットワークを取得する、ネットワークへのアクセスをリクエストする、ネットワークのアンケートを取得する、保存する、提出する
トラベルルールのウォレット証明: スクリーンショットによるウォレット証明を一覧表示する、承認または拒否する
Google Wallet(1.0.1のどのリリースにもまだ含まれていません): Google Wallet認証を開始する、ウォレットのレスポンスを送信する

また、以下の新しいリクエストフィールドも送信できません。

セッションを作成する際のbiometric_consent、tags、user_state
Webhook設定を更新する際のbiometric_consent_mode
トラベルルールの送金を更新する際のbeneficiary_vasp
確定済みレポートの削除に必要なconfirm_delete
1.0.1のどのリリースにもない、データベース検証の新しい16個のフィールド

今後のGoリリースでこれらが追加されるまでは、各ページのcURLリクエストに示されているとおりにHTTP経由で呼び出してください。APIリファレンスのその他のサーバーエンドポイントのページには、すべてその操作のGoサンプルがあります。

ガイド

認証

Model Context Protocol (MCP)

Web SDK

ネイティブSDK

サーバーSDK

連携

Go SDK：KYC・AML・取引モニタリング向け

インストール

クライアントを設定する

セッションを作成する

判定を読み取る

Webhookを検証する

取引をスクリーニングする

Authenticationトークンを検証する

エラー

リストとファイル

Go SDKにまだないエンドポイント

​インストール

​クライアントを設定する

​セッションを作成する

​判定を読み取る

​Webhookを検証する

​取引をスクリーニングする

​Authenticationトークンを検証する

​エラー

​リストとファイル

​Go SDKにまだないエンドポイント

インストール

クライアントを設定する

セッションを作成する

判定を読み取る

Webhookを検証する

取引をスクリーニングする

Authenticationトークンを検証する

エラー

リストとファイル

Go SDKにまだないエンドポイント