feat: implement zoom connector

connectors.go

@@ -52,6 +52,7 @@ import (
 	"github.com/wakflo/extensions/internal/connectors/woocommerce"
 	"github.com/wakflo/extensions/internal/connectors/xero"
 	"github.com/wakflo/extensions/internal/connectors/zohoinventory"
+	"github.com/wakflo/extensions/internal/connectors/zoom"
 	"github.com/wakflo/extensions/internal/logger"
 	sdk "github.com/wakflo/go-sdk/connector"
 )
@@ -103,7 +104,7 @@ func RegisterConnectors() []*sdk.ConnectorPlugin {
 		stripe.NewConnector,         // Stripe
 		openai.NewConnector,         // OpenAI
 		googlecalendar.NewConnector, // Google Calendar
-
+		zoom.NewConnector,           // Zoom
 	}
 
 	// 🛑Do-Not-Edit

internal/connectors/zoom/lib.go

@@ -0,0 +1,35 @@
+// Copyright 2022-present Wakflo
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package zoom
+
+import (
+	sdk "github.com/wakflo/go-sdk/connector"
+)
+
+func NewConnector() (*sdk.ConnectorPlugin, error) {
+	return sdk.CreateConnector(&sdk.CreateConnectorArgs{
+		Name:        "Zoom",
+		Description: "Video conferencing, web conferencing, webinars, screen sharing",
+		Logo:        "logos:zoom",
+		Version:     "0.0.1",
+		Category:    sdk.Apps,
+		Authors:     []string{"Wakflo <integrations@wakflo.com>"},
+		Triggers:    []sdk.ITrigger{},
+		Operations: []sdk.IOperation{
+			NewCreateMeetingOperation(),
+			NewCreateMeetingRegistrantOperation(),
+		},
+	})
+}

internal/connectors/zoom/model.go

@@ -0,0 +1,21 @@
+package zoom
+
+type MeetingRegistrant struct {
+	FirstName             string `json:"first_name"`
+	LastName              string `json:"last_name,omitempty"`
+	Email                 string `json:"email"`
+	Address               string `json:"address,omitempty"`
+	City                  string `json:"city,omitempty"`
+	State                 string `json:"state,omitempty"`
+	Zip                   string `json:"zip,omitempty"`
+	Country               string `json:"country,omitempty"`
+	Phone                 string `json:"phone,omitempty"`
+	Comments              string `json:"comments,omitempty"`
+	Industry              string `json:"industry,omitempty"`
+	JobTitle              string `json:"job_title,omitempty"`
+	NumberOfEmployees     string `json:"no_of_employees,omitempty"`
+	Organization          string `json:"org,omitempty"`
+	PurchasingTimeFrame   string `json:"purchasing_time_frame,omitempty"`
+	RoleInPurchaseProcess string `json:"role_in_purchase_process,omitempty"`
+	Language              string `json:"language,omitempty"`
+}

internal/connectors/zoom/operation_create_meeting.go

@@ -0,0 +1,167 @@
+// Copyright 2022-present Wakflo
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package zoom
+
+import (
+	"encoding/json"
+
+	"github.com/wakflo/go-sdk/autoform"
+	sdk "github.com/wakflo/go-sdk/connector"
+	sdkcore "github.com/wakflo/go-sdk/core"
+)
+
+type createMeetingOperationProps struct {
+	Topic       string `json:"topic"`
+	StartTime   string `json:"start_time"`
+	ScheduleFor string `json:"schedule_for"`
+	Duration    int    `json:"duration"`
+	PreSchedule string `json:"pre_schedule"`
+	Password    string `json:"password"`
+	Agenda      string `json:"agenda"`
+	JoinURL     string `json:"join_url"`
+}
+
+type CreateMeetingOperation struct {
+	options *sdk.OperationInfo
+}
+
+func NewCreateMeetingOperation() *CreateMeetingOperation {
+	return &CreateMeetingOperation{
+		options: &sdk.OperationInfo{
+			Name:        "Create Zoom Meeting",
+			Description: "Create a new Zoom Meeting",
+			Auth:        sharedAuth,
+			Input: map[string]*sdkcore.AutoFormSchema{
+				"topic": autoform.NewShortTextField().
+					SetDisplayName("Meeting's topic").
+					SetDescription("The meeting topic").
+					SetRequired(true).Build(),
+				"start_time": autoform.NewShortTextField().
+					SetDisplayName("Start Time").
+					SetDescription("Meeting start date-time").
+					SetRequired(false).Build(),
+				"schedule_for": autoform.NewShortTextField().
+					SetDisplayName("Schedule for").
+					SetDescription("The email address or user ID of the user to schedule a meeting for.").
+					SetRequired(false).Build(),
+				"duration": autoform.NewNumberField().
+					SetDisplayName("Duration (in Minutes)").
+					SetDescription("Duration of the meeting").
+					SetRequired(false).Build(),
+				"pre_schedule": autoform.NewBooleanField().
+					SetDisplayName("Pre Schedule").
+					SetDescription("Whether the prescheduled meeting was created via the GSuite app.").
+					SetRequired(false).Build(),
+				"password": autoform.NewShortTextField().
+					SetDisplayName("Password").
+					SetDescription("The password required to join the meeting. By default, a password can only have a maximum length of 10 characters and only contain alphanumeric characters and the @, -, _, and * characters.").
+					SetRequired(false).Build(),
+				"agenda": autoform.NewLongTextField().
+					SetDisplayName("Agenda").
+					SetDescription("The meeting's agenda").
+					SetRequired(false).Build(),
+				"join_url": autoform.NewLongTextField().
+					SetDisplayName("Join URL").
+					SetDescription("URL for participants to join the meeting.").
+					SetRequired(false).Build(),
+			},
+			SampleOutput: map[string]interface{}{},
+			ErrorSettings: sdkcore.StepErrorSettings{
+				ContinueOnError: false,
+				RetryOnError:    false,
+			},
+			RequireAuth: true,
+		},
+	}
+}
+
+func (c *CreateMeetingOperation) Run(ctx *sdk.RunContext) (sdk.JSON, error) {
+	input := sdk.InputToType[createMeetingOperationProps](ctx)
+
+	data := map[string]interface{}{
+		"topic":            input.Topic,
+		"agenda":           "My Meeting",
+		"default_password": false,
+		//nolint:mnd
+		"duration":     30,
+		"pre_schedule": false,
+		"timezone":     "UTC",
+		//nolint:mnd
+		"type": 2,
+		"settings": map[string]interface{}{
+			"allow_multiple_devices": true,
+			//nolint:mnd
+			"approval_type":                  2,
+			"audio":                          "telephony",
+			"calendar_type":                  1,
+			"close_registration":             false,
+			"email_notification":             true,
+			"host_video":                     true,
+			"join_before_host":               false,
+			"meeting_authentication":         true,
+			"mute_upon_entry":                false,
+			"participant_video":              false,
+			"private_meeting":                false,
+			"registrants_confirmation_email": true,
+			"registrants_email_notification": true,
+			"registration_type":              1,
+			"show_share_button":              true,
+			"host_save_video_order":          true,
+		},
+	}
+
+	if input.Duration != 0 {
+		data["duration"] = input.Duration
+	}
+	if input.PreSchedule != "" {
+		data["pre_schedule"] = input.PreSchedule
+	}
+	if input.StartTime != "" {
+		data["start_time"] = input.StartTime
+	}
+	if input.ScheduleFor != "" {
+		data["schedule_for"] = input.ScheduleFor
+	}
+	if input.Agenda != "" {
+		data["agenda"] = input.Agenda
+	}
+	if input.JoinURL != "" {
+		data["join_url"] = input.JoinURL
+	}
+	if input.Password != "" {
+		data["[password]"] = input.Password
+	}
+
+	meeting, err := json.Marshal(data)
+	if err != nil {
+		return nil, err
+	}
+
+	reqURL := "https://api.zoom.us/v2/users/me/meetings"
+
+	resp, err := zoomRequest(ctx.Auth.AccessToken, reqURL, meeting)
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
+}
+
+func (c *CreateMeetingOperation) Test(ctx *sdk.RunContext) (sdk.JSON, error) {
+	return c.Run(ctx)
+}
+
+func (c *CreateMeetingOperation) GetInfo() *sdk.OperationInfo {
+	return c.options
+}

internal/connectors/zoom/operation_create_meeting_registration.go

@@ -0,0 +1,144 @@
+// Copyright 2022-present Wakflo
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package zoom
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"github.com/wakflo/go-sdk/autoform"
+	sdk "github.com/wakflo/go-sdk/connector"
+	sdkcore "github.com/wakflo/go-sdk/core"
+)
+
+type createMeetingRegistrantOperationProps struct {
+	MeetingID string `json:"meeting_id"`
+	MeetingRegistrant
+}
+
+type CreateMeetingRegistrantOperation struct {
+	options *sdk.OperationInfo
+}
+
+func NewCreateMeetingRegistrantOperation() *CreateMeetingRegistrantOperation {
+	return &CreateMeetingRegistrantOperation{
+		options: &sdk.OperationInfo{
+			Name:        "Create Zoom Meeting Registrant",
+			Description: "Create and submit a user's registration to a meeting.",
+			Auth:        sharedAuth,
+			Input: map[string]*sdkcore.AutoFormSchema{
+				"meeting_id": autoform.NewShortTextField().
+					SetDisplayName("Meeting ID").
+					SetDescription("The meeting's ID").
+					SetRequired(true).Build(),
+				"first_name": autoform.NewShortTextField().
+					SetDisplayName("First Name").
+					SetDescription("First name").
+					SetRequired(true).Build(),
+				"last_name": autoform.NewShortTextField().
+					SetDisplayName("Last Name").
+					SetDescription("Last name").
+					SetRequired(false).Build(),
+				"email": autoform.NewShortTextField().
+					SetDisplayName("Email").
+					SetDescription("The registrant's email address.").
+					SetRequired(true).Build(),
+				"address": autoform.NewShortTextField().
+					SetDisplayName("Address").
+					SetDescription("The registrant's address.").
+					SetRequired(false).Build(),
+				"city": autoform.NewShortTextField().
+					SetDisplayName("City").
+					SetDescription("The registrant's city.").
+					SetRequired(false).Build(),
+				"state": autoform.NewShortTextField().
+					SetDisplayName("State").
+					SetDescription("The registrant's state or province.").
+					SetRequired(false).Build(),
+				"zip": autoform.NewShortTextField().
+					SetDisplayName("Zip").
+					SetDescription("The registrant's zip or postal code.").
+					SetRequired(false).Build(),
+				"country": autoform.NewShortTextField().
+					SetDisplayName("Country").
+					SetDescription("The registrant's two-letter country code.").
+					SetRequired(false).Build(),
+				"phone": autoform.NewShortTextField().
+					SetDisplayName("Phone").
+					SetDescription("The registrant's phone number.").
+					SetRequired(false).Build(),
+				"comments": autoform.NewLongTextField().
+					SetDisplayName("Phone").
+					SetDescription("The registrant's questions and comments.").
+					SetRequired(false).Build(),
+				"industry": autoform.NewShortTextField().
+					SetDisplayName("Industry").
+					SetDescription("The registrant's industry").
+					SetRequired(false).Build(),
+				"job_title": autoform.NewShortTextField().
+					SetDisplayName("Job Title").
+					SetDescription("The registrant's job title").
+					SetRequired(false).Build(),
+				"no_of_employees": autoform.NewShortTextField().
+					SetDisplayName("Number of Employees").
+					SetDescription("The registrant's number of employees.").
+					SetRequired(false).Build(),
+				"org": autoform.NewShortTextField().
+					SetDisplayName("Organization").
+					SetDescription("The registrant's organization.").
+					SetRequired(false).Build(),
+				"purchasing_time_frame": autoform.NewShortTextField().
+					SetDisplayName("Purchasing time frame").
+					SetDescription("The registrant's purchasing time frame.").
+					SetRequired(false).Build(),
+				"role_in_purchase_process": autoform.NewShortTextField().
+					SetDisplayName("Role in purchase process").
+					SetDescription("The registrant's role in purchase process").
+					SetRequired(false).Build(),
+			},
+			SampleOutput: map[string]interface{}{},
+			ErrorSettings: sdkcore.StepErrorSettings{
+				ContinueOnError: false,
+				RetryOnError:    false,
+			},
+			RequireAuth: true,
+		},
+	}
+}
+
+func (c *CreateMeetingRegistrantOperation) Run(ctx *sdk.RunContext) (sdk.JSON, error) {
+	input := sdk.InputToType[createMeetingRegistrantOperationProps](ctx)
+
+	meetingRegistrant, err := json.Marshal(input)
+	if err != nil {
+		return nil, err
+	}
+
+	reqURL := fmt.Sprintf("https://api.zoom.us/v2/meetings/%s/registrants", input.MeetingID)
+
+	resp, err := zoomRequest(ctx.Auth.AccessToken, reqURL, meetingRegistrant)
+	if err != nil {
+		return nil, err
+	}
+	return resp, nil
+}
+
+func (c *CreateMeetingRegistrantOperation) Test(ctx *sdk.RunContext) (sdk.JSON, error) {
+	return c.Run(ctx)
+}
+
+func (c *CreateMeetingRegistrantOperation) GetInfo() *sdk.OperationInfo {
+	return c.options
+}