Merge pull request #15 from chatbotkit/next

Release go-sdk

Author: pdparchitect

README.md

@@ -108,7 +108,7 @@ client.Integration.Trigger.Execution         // Trigger execution management
 client.Integration.Twilio        // Twilio integrations
 client.Integration.Email         // Email integrations
 client.Integration.McpServer     // MCP server integrations
-client.Integration.Teams         // Teams integrations
+client.Integration.Microsoftteams        // Microsoft Teams integrations
 client.Integration.GoogleChat    // Google Chat integrations
 client.Memory                    // Memory management
 client.Partner                   // Partner operations

portable-embedded-agent

@@ -88,3 +88,14 @@ func (c *DiscordClient) Setup(ctx context.Context, discordID string) (*types.Int
 	}
 	return &result, nil
 }
+
+// Initiate initiates a Discord integration conversation.
+func (c *DiscordClient) Initiate(ctx context.Context, discordID string, req types.DiscordInitiateRequest) (*types.DiscordInitiateResponse, error) {
+	path := fmt.Sprintf("/api/v1/integration/discord/%s/initiate", discordID)
+
+	var result types.DiscordInitiateResponse
+	if err := c.httpClient.Post(ctx, path, req, &result); err != nil {
+		return nil, err
+	}
+	return &result, nil
+}

sdk/integration/discord.go

@@ -86,3 +86,14 @@ func (c *GoogleChatClient) Setup(ctx context.Context, googleChatID string) (*typ
 	}
 	return &result, nil
 }
+
+// Initiate initiates a Google Chat integration conversation.
+func (c *GoogleChatClient) Initiate(ctx context.Context, googleChatID string, req types.GooglechatInitiateRequest) (*types.GooglechatInitiateResponse, error) {
+	path := fmt.Sprintf("/api/v1/integration/googlechat/%s/initiate", googleChatID)
+
+	var result types.GooglechatInitiateResponse
+	if err := c.httpClient.Post(ctx, path, req, &result); err != nil {
+		return nil, err
+	}
+	return &result, nil
+}

sdk/integration/googlechat.go

@@ -88,3 +88,14 @@ func (c *InstagramClient) Setup(ctx context.Context, instagramID string) (*types
 	}
 	return &result, nil
 }
+
+// Initiate initiates an Instagram integration conversation.
+func (c *InstagramClient) Initiate(ctx context.Context, instagramID string, req types.InstagramInitiateRequest) (*types.InstagramInitiateResponse, error) {
+	path := fmt.Sprintf("/api/v1/integration/instagram/%s/initiate", instagramID)
+
+	var result types.InstagramInitiateResponse
+	if err := c.httpClient.Post(ctx, path, req, &result); err != nil {
+		return nil, err
+	}
+	return &result, nil
+}

sdk/integration/instagram.go

@@ -38,32 +38,32 @@ type Client struct {
 	Email *EmailClient
 	// McpServer provides access to MCP server integration resources.
 	McpServer *McpServerClient
-	// Teams provides access to Teams integration resources.
-	Teams *TeamsClient
+	// Microsoftteams provides access to Microsoft Teams integration resources.
+	Microsoftteams *MicrosoftteamsClient
 	// GoogleChat provides access to Google Chat integration resources.
 	GoogleChat *GoogleChatClient
 }
 
 // NewClient creates a new IntegrationClient.
 func NewClient(httpClient *httpclient.Client) *Client {
 	return &Client{
-		httpClient: httpClient,
-		Widget:     NewWidgetClient(httpClient),
-		Slack:      NewSlackClient(httpClient),
-		Discord:    NewDiscordClient(httpClient),
-		WhatsApp:   NewWhatsAppClient(httpClient),
-		Telegram:   NewTelegramClient(httpClient),
-		Messenger:  NewMessengerClient(httpClient),
-		Instagram:  NewInstagramClient(httpClient),
-		Notion:     NewNotionClient(httpClient),
-		Sitemap:    NewSitemapClient(httpClient),
-		Support:    NewSupportClient(httpClient),
-		Extract:    NewExtractClient(httpClient),
-		Trigger:    NewTriggerClient(httpClient),
-		Twilio:     NewTwilioClient(httpClient),
-		Email:      NewEmailClient(httpClient),
-		McpServer:  NewMcpServerClient(httpClient),
-		Teams:      NewTeamsClient(httpClient),
-		GoogleChat: NewGoogleChatClient(httpClient),
+		httpClient:     httpClient,
+		Widget:         NewWidgetClient(httpClient),
+		Slack:          NewSlackClient(httpClient),
+		Discord:        NewDiscordClient(httpClient),
+		WhatsApp:       NewWhatsAppClient(httpClient),
+		Telegram:       NewTelegramClient(httpClient),
+		Messenger:      NewMessengerClient(httpClient),
+		Instagram:      NewInstagramClient(httpClient),
+		Notion:         NewNotionClient(httpClient),
+		Sitemap:        NewSitemapClient(httpClient),
+		Support:        NewSupportClient(httpClient),
+		Extract:        NewExtractClient(httpClient),
+		Trigger:        NewTriggerClient(httpClient),
+		Twilio:         NewTwilioClient(httpClient),
+		Email:          NewEmailClient(httpClient),
+		McpServer:      NewMcpServerClient(httpClient),
+		Microsoftteams: NewMicrosoftteamsClient(httpClient),
+		GoogleChat:     NewGoogleChatClient(httpClient),
 	}
 }

sdk/integration/integration.go

@@ -31,7 +31,7 @@ func TestIntegrationClients(t *testing.T) {
 		{"Twilio", client.Integration.Twilio},
 		{"Email", client.Integration.Email},
 		{"McpServer", client.Integration.McpServer},
-		{"Teams", client.Integration.Teams},
+		{"Microsoftteams", client.Integration.Microsoftteams},
 		{"GoogleChat", client.Integration.GoogleChat},
 	}
 

sdk/integration/integration_test.go

@@ -88,3 +88,14 @@ func (c *MessengerClient) Setup(ctx context.Context, messengerID string) (*types
 	}
 	return &result, nil
 }
+
+// Initiate initiates a Messenger integration conversation.
+func (c *MessengerClient) Initiate(ctx context.Context, messengerID string, req types.MessengerInitiateRequest) (*types.MessengerInitiateResponse, error) {
+	path := fmt.Sprintf("/api/v1/integration/messenger/%s/initiate", messengerID)
+
+	var result types.MessengerInitiateResponse
+	if err := c.httpClient.Post(ctx, path, req, &result); err != nil {
+		return nil, err
+	}
+	return &result, nil
+}

sdk/integration/messenger.go

@@ -0,0 +1,99 @@
+package integration
+
+import (
+	"context"
+	"fmt"
+	"net/url"
+
+	"github.com/chatbotkit/go-sdk/internal/httpclient"
+	"github.com/chatbotkit/go-sdk/internal/params"
+	"github.com/chatbotkit/go-sdk/types"
+)
+
+// MicrosoftteamsClient provides access to Microsoft Teams integration resources.
+type MicrosoftteamsClient struct {
+	httpClient *httpclient.Client
+}
+
+// NewMicrosoftteamsClient creates a new MicrosoftteamsClient.
+func NewMicrosoftteamsClient(httpClient *httpclient.Client) *MicrosoftteamsClient {
+	return &MicrosoftteamsClient{httpClient: httpClient}
+}
+
+// List retrieves a list of Microsoft Teams integrations.
+func (c *MicrosoftteamsClient) List(ctx context.Context, opts *types.MicrosoftteamsIntegrationListParams) (*types.MicrosoftteamsIntegrationListResponse, error) {
+	query := url.Values{}
+	if opts != nil {
+		query = params.BuildListQuery(opts.Cursor, opts.Order, opts.Take, opts.Meta)
+	}
+
+	var result types.MicrosoftteamsIntegrationListResponse
+	if err := c.httpClient.Get(ctx, "/api/v1/integration/microsoftteams/list", query, &result); err != nil {
+		return nil, err
+	}
+	return &result, nil
+}
+
+// Fetch retrieves a Microsoft Teams integration by ID.
+func (c *MicrosoftteamsClient) Fetch(ctx context.Context, microsoftteamsID string) (*types.MicrosoftteamsIntegrationFetchResponse, error) {
+	path := fmt.Sprintf("/api/v1/integration/microsoftteams/%s/fetch", microsoftteamsID)
+
+	var result types.MicrosoftteamsIntegrationFetchResponse
+	if err := c.httpClient.Get(ctx, path, nil, &result); err != nil {
+		return nil, err
+	}
+	return &result, nil
+}
+
+// Create creates a Microsoft Teams integration.
+func (c *MicrosoftteamsClient) Create(ctx context.Context, req types.MicrosoftteamsIntegrationCreateRequest) (*types.MicrosoftteamsIntegrationCreateResponse, error) {
+	var result types.MicrosoftteamsIntegrationCreateResponse
+	if err := c.httpClient.Post(ctx, "/api/v1/integration/microsoftteams/create", req, &result); err != nil {
+		return nil, err
+	}
+	return &result, nil
+}
+
+// Update updates a Microsoft Teams integration.
+func (c *MicrosoftteamsClient) Update(ctx context.Context, microsoftteamsID string, req types.MicrosoftteamsIntegrationUpdateRequest) (*types.MicrosoftteamsIntegrationUpdateResponse, error) {
+	path := fmt.Sprintf("/api/v1/integration/microsoftteams/%s/update", microsoftteamsID)
+
+	var result types.MicrosoftteamsIntegrationUpdateResponse
+	if err := c.httpClient.Post(ctx, path, req, &result); err != nil {
+		return nil, err
+	}
+	return &result, nil
+}
+
+// Delete deletes a Microsoft Teams integration.
+func (c *MicrosoftteamsClient) Delete(ctx context.Context, microsoftteamsID string) (*types.MicrosoftteamsIntegrationDeleteResponse, error) {
+	path := fmt.Sprintf("/api/v1/integration/microsoftteams/%s/delete", microsoftteamsID)
+
+	var result types.MicrosoftteamsIntegrationDeleteResponse
+	if err := c.httpClient.Post(ctx, path, types.MicrosoftteamsIntegrationDeleteRequest{}, &result); err != nil {
+		return nil, err
+	}
+	return &result, nil
+}
+
+// Setup sets up a Microsoft Teams integration.
+func (c *MicrosoftteamsClient) Setup(ctx context.Context, microsoftteamsID string) (*types.MicrosoftteamsIntegrationSetupResponse, error) {
+	path := fmt.Sprintf("/api/v1/integration/microsoftteams/%s/setup", microsoftteamsID)
+
+	var result types.MicrosoftteamsIntegrationSetupResponse
+	if err := c.httpClient.Post(ctx, path, types.MicrosoftteamsIntegrationSetupRequest{}, &result); err != nil {
+		return nil, err
+	}
+	return &result, nil
+}
+
+// Initiate initiates a Microsoft Teams integration conversation.
+func (c *MicrosoftteamsClient) Initiate(ctx context.Context, microsoftteamsID string, req types.TeamsInitiateRequest) (*types.TeamsInitiateResponse, error) {
+	path := fmt.Sprintf("/api/v1/integration/microsoftteams/%s/initiate", microsoftteamsID)
+
+	var result types.TeamsInitiateResponse
+	if err := c.httpClient.Post(ctx, path, req, &result); err != nil {
+		return nil, err
+	}
+	return &result, nil
+}