Merge pull request #103 from RADAR-base/oura-rest-connector

Add Oura Rest Connector implementation

Author: mpgxvii

kafka-connect-oura-source/build.gradle.kts

@@ -0,0 +1,29 @@
+description = "Kafka connector for Oura API source"
+
+dependencies {
+    api(project(":kafka-connect-rest-source"))
+    api(project(":oura-library"))
+    api("io.confluent:kafka-connect-avro-converter:${Versions.confluent}")
+    api("org.radarbase:radar-schemas-commons:${Versions.radarSchemas}")
+    implementation("org.radarbase:radar-commons-kotlin:${Versions.radarCommons}")
+
+    implementation(platform("com.fasterxml.jackson:jackson-bom:${Versions.jackson}"))
+    implementation("com.fasterxml.jackson.dataformat:jackson-dataformat-yaml")
+    implementation("com.fasterxml.jackson.datatype:jackson-datatype-jsr310")
+    implementation("com.google.firebase:firebase-admin:${Versions.firebaseAdmin}")
+    implementation("org.jetbrains.kotlin:kotlin-stdlib-jdk8:1.8.21")
+
+    implementation("io.ktor:ktor-client-auth:${Versions.ktor}")
+    implementation("io.ktor:ktor-client-content-negotiation:${Versions.ktor}")
+    implementation("io.ktor:ktor-serialization-jackson:${Versions.ktor}")
+    implementation("io.ktor:ktor-client-cio-jvm:${Versions.ktor}")
+    implementation("io.ktor:ktor-serialization-kotlinx-json:${Versions.ktor}")
+    implementation("com.fasterxml.jackson.module:jackson-module-kotlin:${Versions.jackson}")
+
+    // Included in connector runtime
+    compileOnly("org.apache.kafka:connect-api:${Versions.kafka}")
+    compileOnly(platform("com.fasterxml.jackson:jackson-bom:${Versions.jackson}"))
+    compileOnly("com.fasterxml.jackson.core:jackson-databind")
+
+    testImplementation("org.apache.kafka:connect-api:${Versions.kafka}")
+}

kafka-connect-oura-source/src/main/java/org/radarbase/connect/rest/oura/AbstractRestSourceConnector.java

@@ -0,0 +1,57 @@
+package org.radarbase.connect.rest.oura;
+
+/*
+ * Copyright 2018 The Hyve
+ *
+ * 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.
+ *
+ */
+
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import org.apache.kafka.connect.connector.Task;
+import org.apache.kafka.connect.source.SourceConnector;
+import org.radarbase.connect.rest.util.VersionUtil;
+
+@SuppressWarnings("unused")
+public abstract class AbstractRestSourceConnector extends SourceConnector {
+  protected OuraRestSourceConnectorConfig config;
+
+  @Override
+  public String version() {
+    return VersionUtil.getVersion();
+  }
+
+  @Override
+  public Class<? extends Task> taskClass() {
+    return OuraSourceTask.class;
+  }
+
+  @Override
+  public List<Map<String, String>> taskConfigs(int maxTasks) {
+    return Collections.nCopies(maxTasks, new HashMap<>(config.originalsStrings()));
+  }
+
+  @Override
+  public void start(Map<String, String> props) {
+    config = getConfig(props);
+  }
+
+  public abstract OuraRestSourceConnectorConfig getConfig(Map<String, String> conf);
+
+  @Override
+  public void stop() {
+  }
+}