diff --git a/gsheet-new-row-to-sfdc-new-contact/Ballerina.toml b/gsheet-new-row-to-salesforce-new-contact/Ballerina.toml similarity index 100% rename from gsheet-new-row-to-sfdc-new-contact/Ballerina.toml rename to gsheet-new-row-to-salesforce-new-contact/Ballerina.toml diff --git a/gsheet-new-row-to-sfdc-new-contact/Readme.md b/gsheet-new-row-to-salesforce-new-contact/Readme.md similarity index 100% rename from gsheet-new-row-to-sfdc-new-contact/Readme.md rename to gsheet-new-row-to-salesforce-new-contact/Readme.md diff --git a/gsheet-new-row-to-sfdc-new-contact/docs/images/sheet_headings.png b/gsheet-new-row-to-salesforce-new-contact/docs/images/sheet_headings.png similarity index 100% rename from gsheet-new-row-to-sfdc-new-contact/docs/images/sheet_headings.png rename to gsheet-new-row-to-salesforce-new-contact/docs/images/sheet_headings.png diff --git a/gsheet-new-row-to-sfdc-new-contact/docs/images/template_flow.png b/gsheet-new-row-to-salesforce-new-contact/docs/images/template_flow.png similarity index 100% rename from gsheet-new-row-to-sfdc-new-contact/docs/images/template_flow.png rename to gsheet-new-row-to-salesforce-new-contact/docs/images/template_flow.png diff --git a/gsheet-new-row-to-sfdc-new-contact/main.bal b/gsheet-new-row-to-salesforce-new-contact/main.bal similarity index 100% rename from gsheet-new-row-to-sfdc-new-contact/main.bal rename to gsheet-new-row-to-salesforce-new-contact/main.bal diff --git a/mysql-record-to-sfdc-new-product/Ballerina.toml b/mysql-record-to-salesforce-new-product/Ballerina.toml similarity index 100% rename from mysql-record-to-sfdc-new-product/Ballerina.toml rename to mysql-record-to-salesforce-new-product/Ballerina.toml diff --git a/mysql-record-to-sfdc-new-product/Readme.md b/mysql-record-to-salesforce-new-product/Readme.md similarity index 100% rename from mysql-record-to-sfdc-new-product/Readme.md rename to mysql-record-to-salesforce-new-product/Readme.md diff --git a/mysql-record-to-sfdc-new-product/docs/images/database headings.png b/mysql-record-to-salesforce-new-product/docs/images/database headings.png similarity index 100% rename from mysql-record-to-sfdc-new-product/docs/images/database headings.png rename to mysql-record-to-salesforce-new-product/docs/images/database headings.png diff --git a/mysql-record-to-sfdc-new-product/docs/images/template_flow.png b/mysql-record-to-salesforce-new-product/docs/images/template_flow.png similarity index 100% rename from mysql-record-to-sfdc-new-product/docs/images/template_flow.png rename to mysql-record-to-salesforce-new-product/docs/images/template_flow.png diff --git a/mysql-record-to-sfdc-new-product/main.bal b/mysql-record-to-salesforce-new-product/main.bal similarity index 75% rename from mysql-record-to-sfdc-new-product/main.bal rename to mysql-record-to-salesforce-new-product/main.bal index 4d8e6db..2ed6e87 100644 --- a/mysql-record-to-sfdc-new-product/main.bal +++ b/mysql-record-to-salesforce-new-product/main.bal @@ -31,22 +31,21 @@ salesforce:Client salesforce = check new ({ token: salesforceAccessToken } }); - mysql:Client mysql = check new (host, user, password, database, port); public function main() returns error? { stream streamOutput = mysql->query( `SELECT name, unitType, currencyISO, productId FROM products WHERE processed = false`); - ProductRecieved[] productsRecieved = check from ProductRecieved items in streamOutput - select items; - foreach ProductRecieved prductRecieved in productsRecieved { + record {|ProductRecieved value;|}|error? productRecieved = streamOutput.next(); + while productRecieved !is error|() { Product product = { - Name: prductRecieved.name, - Product_Unit__c: prductRecieved.unitType, - CurrencyIsoCode: prductRecieved.currencyISO + Name: productRecieved.value.name, + Product_Unit__c: productRecieved.value.unitType, + CurrencyIsoCode: productRecieved.value.currencyISO }; _ = check salesforce->create("Product2", product); _ = check mysql->execute( - `UPDATE products SET processed = true WHERE productId = ${prductRecieved.productId}`); + `UPDATE products SET processed = true WHERE productId = ${productRecieved.value.productId}`); + productRecieved = streamOutput.next(); } } diff --git a/sfdc-new-contact-to-twilio-sms/Ballerina.toml b/salesforce-new-contact-to-twilio-sms/Ballerina.toml similarity index 100% rename from sfdc-new-contact-to-twilio-sms/Ballerina.toml rename to salesforce-new-contact-to-twilio-sms/Ballerina.toml diff --git a/sfdc-new-contact-to-twilio-sms/Readme.md b/salesforce-new-contact-to-twilio-sms/Readme.md similarity index 100% rename from sfdc-new-contact-to-twilio-sms/Readme.md rename to salesforce-new-contact-to-twilio-sms/Readme.md diff --git a/sfdc-new-contact-to-twilio-sms/docs/images/template_flow.png b/salesforce-new-contact-to-twilio-sms/docs/images/template_flow.png similarity index 100% rename from sfdc-new-contact-to-twilio-sms/docs/images/template_flow.png rename to salesforce-new-contact-to-twilio-sms/docs/images/template_flow.png diff --git a/sfdc-new-contact-to-twilio-sms/main.bal b/salesforce-new-contact-to-twilio-sms/main.bal similarity index 97% rename from sfdc-new-contact-to-twilio-sms/main.bal rename to salesforce-new-contact-to-twilio-sms/main.bal index 71fa87a..353aa56 100644 --- a/sfdc-new-contact-to-twilio-sms/main.bal +++ b/salesforce-new-contact-to-twilio-sms/main.bal @@ -22,7 +22,8 @@ configurable string toNumber = ?; listener salesforce:Listener sfdcEventListener = new ({ username: salesforceListenerConfig.username, password: salesforceListenerConfig.password, - channelName: "/data/ContactChangeEvent"}); + channelName: "/data/ContactChangeEvent" +}); final twilio:Client twilio = check new ({ twilioAuth: { diff --git a/servicenow-case-to-salesforce-case/Readme.md b/servicenow-case-to-salesforce-case/Readme.md index 33d26e6..77de22e 100644 --- a/servicenow-case-to-salesforce-case/Readme.md +++ b/servicenow-case-to-salesforce-case/Readme.md @@ -52,7 +52,7 @@ syncdata = "resources/syncdata" # ServiceNow configuration # ========================== -servicenowInstance = "" +serviceNowInstance = "" serviceNowUsername = "" serviceNowPassword = "" diff --git a/servicenow-case-to-salesforce-case/main.bal b/servicenow-case-to-salesforce-case/main.bal index d8907c9..bf7b70a 100644 --- a/servicenow-case-to-salesforce-case/main.bal +++ b/servicenow-case-to-salesforce-case/main.bal @@ -5,7 +5,7 @@ import ballerina/time; import ballerina/url; import ballerinax/salesforce as sf; -configurable string servicenowInstance = ?; +configurable string serviceNowInstance = ?; configurable string syncData = ?; configurable string serviceNowUsername = ?; configurable string serviceNowPassword = ?; @@ -36,10 +36,10 @@ public function main() returns error? { check io:fileWriteString(syncData, check time:civilToString(fetchPeriod.now)); } function fetchCasesFromServiceNow(string fetchFrom, string fetchTill) returns CaseData[]|error { - http:Client servicenow = check new (string `https://${servicenowInstance}.service-now.com/api/sn_customerservice`); - string serviceNowCredentials = check mime:base64Encode(serviceNowUsername + ":" + serviceNowPassword, "UTF-8").ensureType(); + http:Client serviceNow = check new (string `https://${serviceNowInstance}.service-now.com/api/sn_customerservice`); + string serviceNowCredentials = check mime:base64Encode(string `${serviceNowUsername}:${serviceNowPassword}`, "UTF-8").ensureType(); string query = string `sys_created_onBETWEENjavascript:gs.dateGenerate(${fetchFrom})@javascript:gs.dateGenerate(${fetchTill})`; - record {CaseData[] result;} caseResponse = check servicenow->/case( + record {CaseData[] result;} caseResponse = check serviceNow->/case( headers = {"Authorization": "Basic " + serviceNowCredentials}, sysparm_query = check url:encode(query, "UTF-8") ); diff --git a/shopify-customer-to-salesforce-customer/main.bal b/shopify-customer-to-salesforce-customer/main.bal index 7282d9a..cd4d9ba 100644 --- a/shopify-customer-to-salesforce-customer/main.bal +++ b/shopify-customer-to-salesforce-customer/main.bal @@ -3,10 +3,10 @@ import ballerina/regex; import ballerinax/salesforce as sf; configurable sf:ConnectionConfig salesforceConfig = ?; -sf:Client salesforce = check new (salesforceConfig); +final sf:Client salesforce = check new (salesforceConfig); service /salesforce_bridge on new http:Listener(9090) { - resource function post customers(@http:Payload ShopifyCustomer shopifyCustomer) returns error? { + resource function post customers(ShopifyCustomer shopifyCustomer) returns error? { string firstName = shopifyCustomer.first_name ?: regex:split(shopifyCustomer.email, "@")[0]; string lastName = shopifyCustomer.last_name ?: ""; Address? shopifyAddress = shopifyCustomer.default_address;