+ );
+ }
+}
+
+export default QubitroForm;
diff --git a/assets/js/util/integrationInfo.js b/assets/js/util/integrationInfo.js
index 0e7009237..5cfd40e73 100644
--- a/assets/js/util/integrationInfo.js
+++ b/assets/js/util/integrationInfo.js
@@ -31,12 +31,16 @@ import TagoDark from "../../img/channels/community/flows/tago-dark.png";
import Ubidots from "../../img/channels/community/ubidots.png";
import UbidotsDark from "../../img/channels/community/flows/ubidots-dark.png";
import UbidotsIntro from "../../img/channels/community/intro_screens/ubidots.png";
+import Qubitro from "../../img/channels/community/qubitro.png";
+import QubitroDark from "../../img/channels/community/flows/qubitro-dark.png"
+import QubitroIntro from "../../img/channels/community/intro_screens/qubitro.png";
export const integrationImgMap = {
adafruit: AdafruitDark,
aws: AwsDark,
azure: AzureDark,
iot_central: IotCentralDark,
+ qubitro: QubitroDark,
cargo: CargoDark,
my_devices: MyDevicesDark,
datacake: DatacakeDark,
@@ -49,7 +53,7 @@ export const integrationImgMap = {
akenza: AkenzaDark,
};
-export const http_integrations = ["http", "cargo", "my_devices", "akenza", "datacake", "microshare", "tago", "ubidots", "google_sheets"]
+export const http_integrations = ["http", "cargo", "my_devices", "akenza", "datacake", "microshare", "tago", "ubidots", "google_sheets", "qubitro"]
export const mqtt_integrations = ["mqtt", "adafruit"]
export const getAllowedIntegrations = () => {
@@ -231,4 +235,16 @@ export const COMMUNITY_INTEGRATION_TYPES = [
},
introImg: `${UbidotsIntro}`
},
+ {
+ name: "Qubitro",
+ type: "qubitro",
+ img: `${Qubitro}`,
+ info: {
+ title: "The fastest way to ingest data from devices and transform them into actionable information.",
+ desc: "Qubitro is a device data platform that gives superpowers to innovators to build solutions powered by device data.",
+ docLink: "https://docs.qubitro.com/data-sources/lorawan/helium-console",
+ externalLink: "https://www.qubitro.com"
+ },
+ introImg: `${QubitroIntro}`
+ },
];
diff --git a/lib/console/channels/channel.ex b/lib/console/channels/channel.ex
index 827c0aa07..736ba1c74 100644
--- a/lib/console/channels/channel.ex
+++ b/lib/console/channels/channel.ex
@@ -6,7 +6,7 @@ defmodule Console.Channels.Channel do
alias Console.Organizations.Organization
alias Console.Channels.Channel
- @http_types ~w(http cargo my_devices akenza datacake microshare tago ubidots google_sheets)
+ @http_types ~w(http cargo my_devices akenza datacake microshare tago ubidots google_sheets qubitro)
@long_type_names %{
"aws" => "AWS IoT",
"azure" => "Azure IoT Hub",
@@ -23,6 +23,7 @@ defmodule Console.Channels.Channel do
"ubidots" => "Ubidots",
"google_sheets" => "Google Sheets",
"adafruit" => "Adafruit IO",
+ "qubitro" => "Qubitro",
}
@primary_key {:id, :binary_id, autogenerate: true}
diff --git a/lib/console/community/community_channels.ex b/lib/console/community/community_channels.ex
index 90bc6ded8..ac1c047d4 100644
--- a/lib/console/community/community_channels.ex
+++ b/lib/console/community/community_channels.ex
@@ -53,6 +53,11 @@ defmodule Console.CommunityChannels do
|> Map.put(:endpoint, "https://dataplugin.ubidots.com/api/web-hook/#{channel.credentials["webhook_token"]}")
|> Map.put(:method, "post")
|> Map.put(:headers, Jason.encode!(%{}))
+ "qubitro" ->
+ channel
+ |> Map.put(:endpoint, "https://webhook.qubitro.com/integrations/helium")
+ |> Map.put(:method, "post")
+ |> Map.put(:headers, Jason.encode!(%{ "webhookSigningKey" => channel.credentials["qubitro_webhook_key"], "projectId" => channel.credentails["qubitro_projectId"] }))
_ ->
channel
end
@@ -141,6 +146,15 @@ defmodule Console.CommunityChannels do
"url_params" => %{}
})
|> Map.put(:type, (if show_underlying_type, do: "http", else: channel.type))
+ "qubitro" ->
+ channel
+ |> Map.put(:credentials, %{
+ "endpoint" => "https://webhook.qubitro.com/integrations/helium",
+ "headers" => %{ "webhookSigningKey" => channel.credentials["qubitro_webhook_key"], "projectId" => channel.credentails["qubitro_projectId"] },
+ "method" => "post",
+ "url_params" => %{}
+ })
+ |> Map.put(:type, (if show_underlying_type, do: "http", else: channel.type))
_ ->
channel
end
diff --git a/lib/console_web/controllers/v1/channel_controller.ex b/lib/console_web/controllers/v1/channel_controller.ex
index cf8a3fed1..9696f0a36 100644
--- a/lib/console_web/controllers/v1/channel_controller.ex
+++ b/lib/console_web/controllers/v1/channel_controller.ex
@@ -285,6 +285,46 @@ defmodule ConsoleWeb.V1.ChannelController do
end
end
+ def create(conn, %{ "name" => name, "type" => "qubitro", "qubitro_webhook_key" => qubitro_webhook_key, "qubitro_projectId" => qubitro_projectId, "qubitro_app_name" => qubitro_app_name } = attrs) do
+ current_organization = conn.assigns.current_organization
+ allowed_types = Channel.get_allowed_integration_types()
+
+ if "qubitro" in allowed_types do
+ channel_params =
+ %{
+ "credentials" => %{
+ "qubitro_webhook_key" => qubitro_webhook_key,
+ "qubitro_projectId" => qubitro_projectId,
+ "qubitro_app_name" => qubitro_app_name
+ },
+ "name" => name,
+ "type" => "qubitro",
+ "organization_id" => current_organization.id
+ }
+
+ with {:ok, %Channel{} = channel} <- Channels.create_channel(current_organization, channel_params) do
+ channel =
+ channel
+ |> Map.put(:devices, [])
+ |> Map.put(:labels, [])
+
+ AuditActions.create_audit_action(
+ current_organization.id,
+ "v1_api",
+ "channel_controller_create",
+ channel.id,
+ attrs
+ )
+
+ conn
+ |> put_status(:created)
+ |> render("show.json", channel: channel)
+ end
+ else
+ {:error, :bad_request, "This integration type is not allowed on this Console" }
+ end
+ end
+
def create(conn, %{ "name" => name, "type" => "mqtt", "endpoint" => endpoint, "uplink_topic" => uplink_topic, "downlink_topic" => downlink_topic } = attrs) do
current_organization = conn.assigns.current_organization
allowed_types = Channel.get_allowed_integration_types()