initial commit

.gitconfig

@@ -0,0 +1,2 @@
+[core]
+        autocrlf = false

.github/workflows/release.yml

@@ -0,0 +1,27 @@
+name: Attach Custom Connector as release asset
+
+on:
+  release:
+    types: [published]
+
+jobs:
+  build-and-attach:
+    runs-on: windows-latest
+
+    steps:
+    - name: Checkout code
+      uses: actions/checkout@v3
+
+    - name: Set up MSBuild
+      uses: microsoft/setup-msbuild@v1
+
+    - name: Build .mez file
+      run: |
+        msbuild enlyze.pq.proj /p:Configuration=Release
+
+    - name: Upload `.mez` as release asset
+      uses: softprops/action-gh-release@v1
+      with:
+        files: bin/AnyCPU/Release/enlyze-powerbi.mez
+      env:
+        GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.gitignore

@@ -0,0 +1,2 @@
+*.DS_Store
+bin/

.vscode/launch.json

@@ -0,0 +1,14 @@
+{
+    // Use IntelliSense to learn about possible attributes.
+    // Hover to view descriptions of existing attributes.
+    // For more information, visit: https://go.microsoft.com/fwlink/?linkid=830387
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "type": "powerquery",
+            "request": "launch",
+            "name": "Evaluate power query file.",
+            "program": "${workspaceFolder}/${command:AskForPowerQueryFileName}"
+        }
+    ]
+}

.vscode/settings.json

@@ -0,0 +1,5 @@
+{
+  "powerquery.sdk.defaultQueryFile": "${workspaceFolder}\\enlyze.query.pq",
+  "powerquery.sdk.defaultExtension": "${workspaceFolder}\\bin\\AnyCPU\\Debug\\enlyze-powerbi.mez",
+  "powerquery.general.mode": "SDK"
+}

.vscode/tasks.json

@@ -0,0 +1,22 @@
+{
+    "version": "2.0.0",
+    "tasks": [
+        {
+            "label": "Build and deploy",
+            "type": "shell",
+            "command": "powershell.exe",
+            "args": [
+                "-ExecutionPolicy",
+                "Bypass",
+                "-File",
+                "${workspaceFolder}/push-extension.ps1"
+            ],
+            "presentation": {
+                "reveal": "always",
+                "panel": "new"
+            },
+            "group": "build",
+            "problemMatcher": []
+        }
+    ]
+}

ApiClient.pqm

@@ -0,0 +1,70 @@
+let
+    BaseUrl = "https://app.enlyze.com/api/v2",
+    CommonHeaders = [
+        #"Content-Type" = "application/json",
+        #"user-agent" = "enlyze-powerbi/0.1.0"
+    ],
+    CreateHeaders = (apiToken as text) as record =>
+        Record.Combine({CommonHeaders, [#"Authorization" = "Bearer " & apiToken]}),
+    FetchPage = (apiPath as text, cursor as nullable text, optional queryParams as nullable record) =>
+        let
+            apiUrl = BaseUrl & apiPath,
+            apiToken = Extension.CurrentCredential()[Key],
+            headers = CreateHeaders(apiToken),
+            combinedQueryParams =
+                if queryParams <> null then
+                    Record.Combine({queryParams, [cursor = cursor]})
+                else
+                    [cursor = cursor],
+            fieldNames = Record.FieldNames(combinedQueryParams),
+            nullValueFields = List.Select(fieldNames, each Record.Field(combinedQueryParams, _) = null),
+            queryParamsNonNull = Record.RemoveFields(combinedQueryParams, nullValueFields),
+            queryString = Uri.BuildQueryString(queryParamsNonNull),
+            apiUrlWithQueryParams = if Text.Length(queryString) > 0 then apiUrl & "?" & queryString else apiUrl,
+            parsedResponse = Json.Document(Web.Contents(apiUrlWithQueryParams, [Headers = headers]))
+        in
+            parsedResponse,
+    FetchPaginated = (apiPath as text, cursor as nullable text, optional queryParams as nullable record) as list =>
+        let
+            currentPage = FetchPage(apiPath, cursor, queryParams),
+            nextCursor = currentPage[metadata][next_cursor],
+            data = currentPage[data],
+            remainingData = if nextCursor = null then {} else @FetchPaginated(apiPath, nextCursor, queryParams)
+        in
+            List.Combine({data, remainingData}),
+    PostRequestPage = (apiPath as text, body as record, cursor as nullable text) as record =>
+        let
+            bodyWithCursor = if cursor <> null then Record.Combine({body, [cursor = cursor]}) else body,
+            url = BaseUrl & apiPath,
+            apiToken = Extension.CurrentCredential()[Key],
+            headers = CreateHeaders(apiToken),
+            response = Web.Contents(
+                url,
+                [
+                    Headers = headers,
+                    Content = Json.FromValue(bodyWithCursor),
+                    ManualStatusHandling = {400, 401, 403, 404, 422, 500}
+                ]
+            ),
+            statusCode = Value.Metadata(response)[Response.Status],
+            parsedResponse =
+                if statusCode = 200 then
+                    Json.Document(response)
+                else
+                    error "HTTP Error: " & Text.From(statusCode) & ". Response body: " & Text.FromBinary(response)
+        in
+            parsedResponse,
+    PaginatedPostRequest = (apiPath as text, body as record, optional cursor as nullable text) as list =>
+        let
+            currentPage = PostRequestPage(apiPath, body, cursor),
+            dataMaybeRecord = currentPage[data],
+            data = if Type.Is(Value.Type(dataMaybeRecord), List.Type) then dataMaybeRecord else {dataMaybeRecord},
+            nextCursor = currentPage[metadata][next_cursor],
+            remainingData = if nextCursor = null then {} else @PaginatedPostRequest(apiPath, body, nextCursor)
+        in
+            List.Combine({data, remainingData})
+in
+    [
+        FetchPaginated = FetchPaginated,
+        PaginatedPostRequest = PaginatedPostRequest
+    ]

CONTRIBUTING.md

@@ -0,0 +1,37 @@
+# Contributing
+
+We are very excited you are interested in helping with our ENLYZE Power BI Integration! Let's get you started, even if you don't have any previous open-source experience!
+
+## New to Open Source?
+
+Take a look at [How to Contribute to an Open Source Project on GitHub](https://egghead.io/courses/how-to-contribute-to-an-open-source-project-on-github)
+
+## Where to ask Questions?
+
+Check our [Github Issues](https://github.com/enlyze/enlyze-powerbi/issues) to see if someone has already answered your question.
+
+## Primer
+
+In case you are new to Power BI Custom Connector development, [this guide](https://learn.microsoft.com/en-us/power-query/install-sdk) may help you get started quickly.
+
+### Prerequisites
+
+In order to get your development setup up and running, you will need
+
+1. A Windows (Virtual) Machine
+2. [Microsoft Visual Studio](https://visualstudio.microsoft.com/) or [Visual Studio Code](https://code.visualstudio.com/)
+3. The latest version of the [Microsoft Power Query SDK](https://learn.microsoft.com/en-us/power-query/install-sdk)
+
+### Project Setup
+
+1. Fork the [enlyze-powerbi](https://github.com/enlyze/enlyze-powerbi) repository.
+2. Clone the forked repository.
+
+## Modifying Code
+
+- Open the `enlyze-power` project in your IDE and start modifying the code.
+- The [Microsoft Power Query SDK](https://learn.microsoft.com/en-us/power-query/install-sdk) will auto-format your changes.
+
+## Pull Request
+
+Reference the relevant issue or pull request and give a clear description of changes/features added when submitting a pull request.

LICENSE

@@ -0,0 +1,18 @@
+Copyright 2024 ENLYZE GmbH <[email protected]>
+
+Permission is hereby granted, free of charge, to any person obtaining a copy of this
+software and associated documentation files (the "Software"), to deal in the Software
+without restriction, including without limitation the rights to use, copy, modify,
+merge, publish, distribute, sublicense, and/or sell copies of the Software, and to
+permit persons to whom the Software is furnished to do so, subject to the following
+conditions:
+
+The above copyright notice and this permission notice shall be included in all copies
+or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED,
+INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A
+PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
+HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF
+CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE
+OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

README.md

@@ -0,0 +1,32 @@
+# ENLYZE Power BI Integration
+
+This Power BI Integration enables users of [ENLYZE](https://enlyze.com) to use their production data in Power BI. The project is based on the [Power Query Connector Development SDK](https://github.com/microsoft/vscode-powerquery-sdk).
+
+## Features
+
+The ENLYZE Power BI Integration currently supports querying the following resources:
+
+- Sites
+- Machines
+- Production Runs
+- Products
+- Downtimes
+- Productivity Metrics for machines
+
+## Installation
+
+If you are looking for a more detailed guide, head over to [our docs](https://docs.enlyze.com/platform/power-bi/installation) (German only).
+
+In order to get started with the ENLYZE Power BI Integration,
+
+1. Download the `enlyze-powerbi.mez` file from the [Latest Release](https://github.com/enlyze/enlyze-powerbi/releases/latest/download/enlyze-powerbi.mez)
+2. Follow the steps [described in the official documentation](https://learn.microsoft.com/en-us/power-bi/connect-data/desktop-connector-extensibility#custom-connectors).
+3. Restart Power BI
+
+## Usage Guide
+
+If you want use the ENLYZE Power BI Integration, [our docs](https://docs.enlyze.com/platform/power-bi) are a great place to start (German only).
+
+## Contributing
+
+Check out [CONTRIBUTING.md](/CONTRIBUTING.md)

downtimes/Downtimes.TableSchema.pqm

@@ -0,0 +1,16 @@
+let
+    DowntimesTableSchema = type table [
+        uuid = text,
+        machine = text,
+        #"type" = text,
+        start = datetimezone,
+        end = nullable datetimezone,
+        updated_first_name = nullable text,
+        updated_last_name = nullable text,
+        updated_timestamp = nullable datetimezone,
+        reason_uuid = nullable text,
+        reason_name = nullable text,
+        reason_category = nullable text
+    ]
+in
+    DowntimesTableSchema

downtimes/Downtimes.Transform.pqm

@@ -0,0 +1,40 @@
+let
+    loadModule = (fileName as text) =>
+        let
+            binary = Extension.Contents(fileName), asText = Text.FromBinary(binary)
+        in
+            try
+                Expression.Evaluate(asText, #shared) catch (e) =>
+                    error
+                        [
+                            Reason = "Extension.LoadModule Failure",
+                            Message.Format = "Loading '#{0}' failed - '#{1}': '#{2}'",
+                            Message.Parameters = {fileName, e[Reason], e[Message]},
+                            Detail = [File = fileName, Error = e]
+                        ],
+    TableSchema = loadModule("Downtimes.TableSchema.pqm"),
+    Table.ChangeType = loadModule("Table.ChangeType.pqm"),
+    TimeseriesData = loadModule("TimeseriesData.pqm"),
+    TransformDowntimes = (downtimes as list) as table =>
+        let
+            downtimesTable = Table.FromList(downtimes, Splitter.SplitByNothing(), null, null, ExtraValues.Error),
+            namedTable = Value.ReplaceMetadata(downtimesTable, Value.Metadata(downtimesTable) & [Name = "Downtimes"]),
+            expandedTable = Table.ExpandRecordColumn(
+                namedTable, "Column1", {"uuid", "machine", "comment", "type", "updated", "reason", "start", "end"}
+            ),
+            expandedUpdated = Table.ExpandRecordColumn(
+                expandedTable,
+                "updated",
+                {"first_name", "last_name", "timestamp"},
+                {"updated_first_name", "updated_last_name", "updated_timestamp"}
+            ),
+            expandedReason = Table.ExpandRecordColumn(
+                expandedUpdated,
+                "reason",
+                {"uuid", "name", "category"},
+                {"reason_uuid", "reason_name", "reason_category"}
+            )
+        in
+            Table.ChangeType(expandedReason, TableSchema)
+in
+    [TransformDowntimes = TransformDowntimes]