Start implementing api client

build.gradle

@@ -13,6 +13,14 @@ repositories {
 dependencies {
     testCompile group: 'junit', name: 'junit', version: '4.12'
     compile fileTree(dir: 'libs', include: '*.jar')
+    compile 'io.github.openfeign:feign-core:11.1'
+    compile 'io.github.openfeign:feign-httpclient:11.1'
+    compile 'io.github.openfeign:feign-gson:11.1'
+
+    compileOnly 'org.projectlombok:lombok:1.18.20'
+    annotationProcessor 'org.projectlombok:lombok:1.18.20'
+    testCompileOnly 'org.projectlombok:lombok:1.18.20'
+    testAnnotationProcessor 'org.projectlombok:lombok:1.18.20'
 }
 
 // See https://github.com/JetBrains/gradle-intellij-plugin/

src/main/java/com/armstrongconsulting/acprotasks/AcproRepository.java

@@ -2,25 +2,34 @@ package com.armstrongconsulting.acprotasks;
 
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
+import com.armstrongconsulting.acprotasks.client.AcproConnector;
 import com.intellij.openapi.progress.ProgressIndicator;
 import com.intellij.tasks.Task;
 import com.intellij.tasks.TaskRepositoryType;
 import com.intellij.tasks.impl.BaseRepository;
 import com.intellij.util.xmlb.annotations.Tag;
 
+import feign.FeignException;
+
 @Tag(AcproRepositoryType.NAME)
 public class AcproRepository extends BaseRepository
 {
+    private final Logger logger = LoggerFactory.getLogger(AcproRepository.class);
+
+    private String apiKey = null;
 
     public AcproRepository(TaskRepositoryType type)
     {
         super(type);
     }
 
-    public AcproRepository(BaseRepository other)
+    public AcproRepository(AcproRepository other)
     {
         super(other);
+        this.apiKey = other.apiKey;
     }
 
     public AcproRepository()
@@ -30,7 +39,7 @@ public class AcproRepository extends BaseRepository
     @Override
     public @Nullable Task findTask(@NotNull String id) throws Exception
     {
-        return new AcproTask();
+        return null;
     }
 
     @Override
@@ -40,18 +49,55 @@ public class AcproRepository extends BaseRepository
     }
 
     @Override
-    public Task[] getIssues(@Nullable String query, int offset, int limit, boolean withClosed)
-        throws Exception
+    public Task[] getIssues(@Nullable String query, int offset, int limit, boolean withClosed,
+        @NotNull ProgressIndicator cancelled) throws Exception
     {
-        System.out.println("Searching for issues (1): " + query);
-        return new Task[]{new AcproTask()};
+        if (apiKey == null)
+        {
+            apiKey = AcproConnector.getClient(getUrl()).getApiKey(getUsername(), getPassword(), 28800);
+        }
+        return AcproConnector.getClient(getUrl()).getItems(query, offset, limit, apiKey).stream().peek(a -> logger.warn(a.toString())).map(AcproTask::new)
+            .toArray(AcproTask[]::new);
     }
 
     @Override
-    public Task[] getIssues(@Nullable String query, int offset, int limit, boolean withClosed,
-        @NotNull ProgressIndicator cancelled) throws Exception
+    public @Nullable CancellableConnection createCancellableConnection()
+    {
+        return new CancellableConnection()
+        {
+            @Override
+            protected void doTest() throws Exception
+            {
+                try
+                {
+                    if (apiKey != null)
+                    {
+                        return;
+                    }
+
+                    apiKey = AcproConnector.getClient(getUrl()).getApiKey(getUsername(), getPassword(), 28800);
+                }
+                catch (FeignException.Unauthorized e)
+                {
+                    throw new RuntimeException("Wrong username or password");
+                }
+                catch (FeignException.FeignClientException e)
+                {
+                    throw new RuntimeException("Connection failed");
+                }
+            }
+
+            @Override
+            public void cancel()
+            {
+                // not cancellable
+            }
+        };
+    }
+
+    @Override
+    public void initializeRepository()
     {
-        System.out.println("Searching for issues (2): " + query);
-        return new Task[]{new AcproTask()};
+        logger.info("Initialize repository");
     }
 }

src/main/java/com/armstrongconsulting/acprotasks/AcproTask.java

@@ -7,6 +7,7 @@ import javax.swing.*;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 
+import com.armstrongconsulting.acprotasks.client.model.AcproItem;
 import com.intellij.tasks.Comment;
 import com.intellij.tasks.Task;
 import com.intellij.tasks.TaskType;
@@ -15,22 +16,33 @@ import icons.TasksIcons;
 
 public class AcproTask extends Task
 {
+    private String id;
+    private String summary;
+    private String description;
+
+    public AcproTask(AcproItem item)
+    {
+        this.id = String.valueOf(item.getId());
+        this.summary = item.getTitle();
+        this.description = item.getDescription();
+    }
+
     @Override
     public @NotNull String getId()
     {
-        return "ID 123";
+        return id;
     }
 
     @Override
     public @NotNull String getSummary()
     {
-        return "A new a.c.pro task";
+        return summary;
     }
 
     @Override
     public @Nullable String getDescription()
     {
-        return "a.c.pro task description";
+        return description;
     }
 
     @Override
@@ -78,6 +90,6 @@ public class AcproTask extends Task
     @Override
     public @Nullable String getIssueUrl()
     {
-        return null;
+        return "https://www.acpro.at/item/" + id;
     }
 }

src/main/java/com/armstrongconsulting/acprotasks/client/AcproClient.java

@@ -0,0 +1,21 @@
+package com.armstrongconsulting.acprotasks.client;
+
+import java.util.List;
+
+import com.armstrongconsulting.acprotasks.client.model.AcproItem;
+
+import feign.Headers;
+import feign.Param;
+import feign.RequestLine;
+
+public interface AcproClient
+{
+    @RequestLine("GET /api_key?user={user}&password={password}&expires_after_seconds={expires_after_seconds}")
+    String getApiKey(@Param("user") String user, @Param("password") String password,
+        @Param("expires_after_seconds") Integer timeToLive);
+
+    @RequestLine("GET /items?q=title:{title}&start={offset}&count={limit}&api_key={apiKey}")
+    @Headers("Accept: application/json")
+    List<AcproItem> getItems(@Param("title") String titleContains, @Param("offset") Integer offset,
+        @Param("limit") Integer limit, @Param("apiKey") String apiKey);
+}

src/main/java/com/armstrongconsulting/acprotasks/client/AcproConnector.java

@@ -0,0 +1,30 @@
+package com.armstrongconsulting.acprotasks.client;
+
+import com.sun.istack.NotNull;
+
+import feign.Feign;
+import feign.Logger;
+import feign.gson.GsonDecoder;
+import feign.gson.GsonEncoder;
+import feign.httpclient.ApacheHttpClient;
+
+public class AcproConnector
+{
+    private static AcproClient client;
+
+    public static AcproClient getClient(@NotNull String url)
+    {
+        if (client != null)
+        {
+            return client;
+        }
+
+        return Feign.builder()
+            .client(new ApacheHttpClient())
+            .encoder(new GsonEncoder())
+            .decoder(new GsonDecoder())
+            .logger(new Logger.JavaLogger(AcproClient.class))
+            .logLevel(Logger.Level.FULL)
+            .target(AcproClient.class, url);
+    }
+}

src/main/java/com/armstrongconsulting/acprotasks/client/model/AcproItem.java

@@ -0,0 +1,13 @@
+package com.armstrongconsulting.acprotasks.client.model;
+
+import lombok.Data;
+import lombok.ToString;
+
+@Data
+@ToString
+public class AcproItem
+{
+    private Long id;
+    private String title;
+    private String description;
+}