This is an automated email from the ASF dual-hosted git repository. bossenti pushed a commit to branch 2128-deprecated-adapters in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit a7f4d26e9057a2d0d2705df3c5ba0fd7d114e4e7 Author: bossenti <[email protected]> AuthorDate: Mon Nov 6 14:51:32 2023 +0100 refactor(#2128): deprecate legacy adapters --- .../adapters/coindesk/CoindeskBitcoinAdapter.java | 1 + .../connect/adapters/coindesk/Currency.java | 1 + .../connect/adapters/coindesk/model/Bpi.java | 1 + .../adapters/coindesk/model/CoindeskRawModel.java | 1 + .../connect/adapters/coindesk/model/EUR.java | 1 + .../connect/adapters/coindesk/model/GBP.java | 1 + .../connect/adapters/coindesk/model/Time.java | 1 + .../connect/adapters/coindesk/model/USD.java | 1 + .../connect/adapters/flic/FlicMQTTAdapter.java | 1 + .../connect/adapters/flic/FlicOutput.java | 1 + .../connect/adapters/flic/FlicUtils.java | 1 + .../connect/adapters/gdelt/GdeltAdapter.java | 214 ----------- .../connect/adapters/iex/IexCloudAdapter.java | 51 --- .../connect/adapters/iex/IexCloudNewsAdapter.java | 119 ------ .../connect/adapters/iex/IexCloudStockAdapter.java | 92 ----- .../connect/adapters/iex/model/IexNewsData.java | 120 ------ .../connect/adapters/iex/model/IexStockData.java | 410 --------------------- .../adapters/sensemap/OpenSenseMapAdapter.java | 374 ------------------- .../connect/adapters/sensemap/SensorNames.java | 136 ------- .../adapters/sensemap/model/CurrentLocation.java | 62 ---- .../connect/adapters/sensemap/model/Geometry.java | 62 ---- .../adapters/sensemap/model/LastMeasurement.java | 50 --- .../connect/adapters/sensemap/model/Loc.java | 50 --- .../connect/adapters/sensemap/model/SenseBox.java | 122 ------ .../connect/adapters/sensemap/model/Sensor.java | 90 ----- .../connect/adapters/slack/SlackAdapter.java | 1 + .../connect/adapters/slack/SlackConsumer.java | 1 + .../connect/adapters/ti/TISensorTag.java | 1 + .../adapters/wikipedia/WikipediaAdapter.java | 1 + .../wikipedia/WikipediaEditedArticlesAdapter.java | 1 + .../wikipedia/WikipediaModelConverter.java | 1 + .../wikipedia/WikipediaNewArticlesAdapter.java | 1 + .../adapters/wikipedia/WikipediaSseConsumer.java | 1 + .../connect/adapters/wikipedia/model/Length.java | 1 + .../connect/adapters/wikipedia/model/Meta.java | 1 + .../connect/adapters/wikipedia/model/Revision.java | 1 + .../adapters/wikipedia/model/WikipediaModel.java | 1 + .../documentation.md | 36 -- .../icon.png | Bin 33450 -> 0 bytes .../strings.en | 21 -- .../documentation.md | 42 --- .../icon.png | Bin 15675 -> 0 bytes .../strings.en | 25 -- .../documentation.md | 41 --- .../icon.png | Bin 15675 -> 0 bytes .../strings.en | 25 -- 46 files changed, 23 insertions(+), 2142 deletions(-) diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/CoindeskBitcoinAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/CoindeskBitcoinAdapter.java index cc982ecb8..bb222aa6c 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/CoindeskBitcoinAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/CoindeskBitcoinAdapter.java @@ -49,6 +49,7 @@ import java.util.HashMap; import java.util.Map; import java.util.concurrent.TimeUnit; +@Deprecated(since = "0.93.0", forRemoval = true) public class CoindeskBitcoinAdapter implements StreamPipesAdapter, IPullAdapter { public static final String ID = "org.apache.streampipes.connect.adapters.coindesk"; diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/Currency.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/Currency.java index 1e6233402..763b6a304 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/Currency.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/Currency.java @@ -18,6 +18,7 @@ package org.apache.streampipes.connect.adapters.coindesk; +@Deprecated(since = "0.93.0", forRemoval = true) public enum Currency { EUR, GBP, diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Bpi.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Bpi.java index f9f6b0022..b2bb23a49 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Bpi.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Bpi.java @@ -25,6 +25,7 @@ import jakarta.annotation.Generated; @Generated("net.hexar.json2pojo") @SuppressWarnings("unused") +@Deprecated(since = "0.93.0", forRemoval = true) public class Bpi { @SerializedName("EUR") diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/CoindeskRawModel.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/CoindeskRawModel.java index d8d82b954..717fe2ab0 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/CoindeskRawModel.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/CoindeskRawModel.java @@ -24,6 +24,7 @@ import jakarta.annotation.Generated; @Generated("net.hexar.json2pojo") @SuppressWarnings("unused") +@Deprecated(since = "0.93.0", forRemoval = true) public class CoindeskRawModel { @SerializedName("bpi") diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/EUR.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/EUR.java index d2f4439dd..02742edd5 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/EUR.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/EUR.java @@ -25,6 +25,7 @@ import jakarta.annotation.Generated; @Generated("net.hexar.json2pojo") @SuppressWarnings("unused") +@Deprecated(since = "0.93.0", forRemoval = true) public class EUR { @SerializedName("code") diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/GBP.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/GBP.java index 00f1d4a30..dbb8ec660 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/GBP.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/GBP.java @@ -24,6 +24,7 @@ import jakarta.annotation.Generated; @Generated("net.hexar.json2pojo") @SuppressWarnings("unused") +@Deprecated(since = "0.93.0", forRemoval = true) public class GBP { @SerializedName("code") diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Time.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Time.java index 7dab9399c..41364e781 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Time.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Time.java @@ -24,6 +24,7 @@ import jakarta.annotation.Generated; @Generated("net.hexar.json2pojo") @SuppressWarnings("unused") +@Deprecated(since = "0.93.0", forRemoval = true) public class Time { @SerializedName("updated") diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/USD.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/USD.java index ae7879a44..38f6b62ce 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/USD.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/USD.java @@ -24,6 +24,7 @@ import jakarta.annotation.Generated; @Generated("net.hexar.json2pojo") @SuppressWarnings("unused") +@Deprecated(since = "0.93.0", forRemoval = true) public class USD { @SerializedName("code") diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicMQTTAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicMQTTAdapter.java index 5f613ec86..56477fb6d 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicMQTTAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicMQTTAdapter.java @@ -39,6 +39,7 @@ import com.google.gson.Gson; import java.util.Map; +@Deprecated(since = "0.93.0", forRemoval = true) public class FlicMQTTAdapter implements StreamPipesAdapter { private MqttConsumer mqttConsumer; diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicOutput.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicOutput.java index eed4dd437..97c793fc0 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicOutput.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicOutput.java @@ -23,6 +23,7 @@ import com.google.gson.annotations.SerializedName; import jakarta.annotation.Generated; @Generated("net.hexar.json2pojo") +@Deprecated(since = "0.93.0", forRemoval = true) public class FlicOutput { @SerializedName("timestamp") diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicUtils.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicUtils.java index 118a68ed4..3c10e4cd2 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicUtils.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/flic/FlicUtils.java @@ -30,6 +30,7 @@ import java.util.HashMap; import java.util.List; import java.util.Map; +@Deprecated(since = "0.93.0", forRemoval = true) public class FlicUtils { public static final String TIMESTAMP_KEY = "timestamp"; public static final String BUTTON_ID_KEY = "button_id"; diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/gdelt/GdeltAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/gdelt/GdeltAdapter.java deleted file mode 100644 index 6e746d037..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/gdelt/GdeltAdapter.java +++ /dev/null @@ -1,214 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.gdelt; - -//public class GdeltAdapter extends PullAdapter { -// -// public static final String ID = "org.apache.streampipes.connect.adapters.gdelt"; -// -// -// private String url = "http://data.gdeltproject.org/gdeltv2/lastupdate.txt";; -// -// public GdeltAdapter() { -// super(); -// } -// -// public GdeltAdapter(SpecificAdapterStreamDescription adapterDescription) { -// super(adapterDescription); -// } -// -// @Override -// protected PollingSettings getPollingInterval() { -// return PollingSettings.from(TimeUnit.MINUTES, 15); -// } -// -// @Override -// public SpecificAdapterStreamDescription declareModel() { -// SpecificAdapterStreamDescription description = SpecificDataStreamAdapterBuilder.create(ID) -// .withAssets(Assets.DOCUMENTATION, Assets.ICON) -// .withLocales(Locales.EN) -// .build(); -// return description; -// } -// -// public List<Map<String, Object>> getEvents() { -// -// List<Map<String, Object>> eventResults = new ArrayList<>(); -// return eventResults; -// } -// -// @Override -// protected void pullData() { -// try { -// BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(new URL(url).openStream())); -// String firstLine = bufferedReader.readLine(); -// String[] parts = firstLine.split(" "); -// URL zipFileUrl = new URL(parts[2]); -// bufferedReader.close(); -// ZipInputStream zipInputStream = new ZipInputStream(zipFileUrl.openStream()); -// BufferedReader zipBufferedReader = new BufferedReader(new InputStreamReader(zipInputStream)); -// zipInputStream.getNextEntry(); -// CSVReader csvReader = new CSVReader(zipBufferedReader); -// String[] nextRecord; -// while ((nextRecord = csvReader.readNext()) != null) { -// -// Map<String, Object> event = new HashMap<>(); -// -// event.put("global_event_id", nextRecord[0]); -// event.put("day", nextRecord[1]); -// event.put("month_year", nextRecord[2]); -// event.put("year", nextRecord[3]); -// event.put("fraction_date", nextRecord[4]); -// -// event.put("actor_1_code", nextRecord[5]); -// event.put("actor_1_name", nextRecord[6]); -// event.put("actor_1_country_code", nextRecord[7]); -// event.put("actor_1_known_group_code", nextRecord[8]); -// event.put("actor_1_ethnic_code", nextRecord[9]); -// event.put("actor_1_religion_1_code", nextRecord[10]); -// event.put("actor_1_religion_2_code", nextRecord[11]); -// event.put("actor_1_type_1_code", nextRecord[12]); -// event.put("actor_1_type_2_code", nextRecord[13]); -// event.put("actor_1_type_3_code", nextRecord[14]); -// -// event.put("actor_2_code", nextRecord[15]); -// event.put("actor_2_name", nextRecord[16]); -// event.put("actor_2_country_code", nextRecord[17]); -// event.put("actor_2_known_group_code", nextRecord[18]); -// event.put("actor_2_ethnic_code", nextRecord[19]); -// event.put("actor_2_religion_1_code", nextRecord[20]); -// event.put("actor_2_religion_2_code", nextRecord[21]); -// event.put("actor_2_type_1_code", nextRecord[22]); -// event.put("actor_2_type_2_code", nextRecord[23]); -// event.put("actor_2_type_3_code", nextRecord[24]); -// -// event.put("source_url", nextRecord[60]); -// adapterPipeline.process(event); -// -// } -// } catch (Exception e) { -// e.printStackTrace(); -// } -// -// } -// -// @Override -// public void stopAdapter() throws AdapterException { -// -// } -// -// @Override -// public Adapter getInstance(SpecificAdapterStreamDescription adapterDescription) { -// return new GdeltAdapter(adapterDescription); -// } -// -// @Override -// public GuessSchema getSchema(SpecificAdapterStreamDescription adapterDescription) { -// GuessSchema guessSchema = new GuessSchema(); -// EventSchema eventSchema = new EventSchema(); -// -// List<EventProperty> allProperties = new ArrayList<>(); -// allProperties.add(PrimitivePropertyBuilder.create(Datatypes.Integer, "global_event_id").label("Global Event ID") -// .description("Globally unique identifier").build()); -// allProperties.add(PrimitivePropertyBuilder.create(Datatypes.Integer, "day").label("Day") -// .description("Date the event took place in YYYYMMDD format").build()); -// allProperties.add(PrimitivePropertyBuilder.create(Datatypes.Integer, "month_year").label("MonthYear") -// .description("Date the event took place in YYYYMM format").build()); -// allProperties.add(PrimitivePropertyBuilder.create(Datatypes.Integer, "year").label("Year") -// .description("Date the event took place in YYYY format").build()); -// allProperties.add(PrimitivePropertyBuilder.create(Datatypes.Float, "fraction_date").label("FractionDate") -// .description( -// "Date the event took place in YYYY.FFFF format (where FFFF is the percentage of the year completed)") -// .build()); -// -// allProperties.add(PrimitivePropertyBuilder.create(Datatypes.String, "actor_1_code").label("Actor1Code") -// .description("The complete raw CAMEO code for Actor1").build()); -// allProperties.add(PrimitivePropertyBuilder.create(Datatypes.String, "actor_1_name").label("Actor1Name") -// .description("The actual name of the Actor1").build()); -// allProperties.add( -// PrimitivePropertyBuilder.create(Datatypes.String, "actor_1_country_code").label("Actor1CountryCode") -// .description("The 3-character CAMEO code for the country affiliation of Actor1").build()); -// allProperties.add( -// PrimitivePropertyBuilder.create(Datatypes.String, "actor_1_known_group_code").label("Actor1KnownGroupCode") -// .description("The CAMEO code if Actor 1 is a known IGO/NGO/rebel organization").build()); -// allProperties -// .add(PrimitivePropertyBuilder.create(Datatypes.String, "actor_1_ethnic_code").label("Actor1EthnicCode") -// .description("The CAMEO code if the source document specifies the ethnic affiliation of Actor1").build()); -// allProperties.add( -// PrimitivePropertyBuilder.create(Datatypes.String, "actor_1_religion_1_code").label("Actor1Religion1Code") -// .description("The CAMEO code if the source document specifies the religious affiliation of Actor1") -// .build()); -// allProperties.add( -// PrimitivePropertyBuilder.create(Datatypes.String, "actor_1_religion_2_code").label("Actor1Religion2Code") -// .description("The CAMEO code if the source document specifies multiple religious affiliations of Actor1") -// .build()); -// allProperties -// .add(PrimitivePropertyBuilder.create(Datatypes.String, "actor_1_type_1_code").label("Actor1Type1Code") -// .description("The 3-character CAMEO code of the CAMEO “type” or “role” of Actor1").build()); -// allProperties -// .add(PrimitivePropertyBuilder.create(Datatypes.String, "actor_1_type_2_code").label("Actor1Type2Code") -// .description("The 3-character CAMEO code of the CAMEO “type” or “role” of Actor1").build()); -// allProperties -// .add(PrimitivePropertyBuilder.create(Datatypes.String, "actor_1_type_3_code").label("Actor1Type3Code") -// .description("The 3-character CAMEO code of the CAMEO “type” or “role” of Actor1").build()); -// -// allProperties.add(PrimitivePropertyBuilder.create(Datatypes.String, "actor_2_code").label("Actor2Code") -// .description("The complete raw CAMEO code for Actor2").build()); -// allProperties.add(PrimitivePropertyBuilder.create(Datatypes.String, "actor_2_name").label("Actor2Name") -// .description("The actual name of the Actor2").build()); -// allProperties.add( -// PrimitivePropertyBuilder.create(Datatypes.String, "actor_2_country_code").label("Actor2CountryCode") -// .description("The 3-character CAMEO code for the country affiliation of Actor2").build()); -// allProperties.add( -// PrimitivePropertyBuilder.create(Datatypes.String, "actor_2_known_group_code").label("Actor2KnownGroupCode") -// .description("The CAMEO code if Actor 1 is a known IGO/NGO/rebel organization").build()); -// allProperties -// .add(PrimitivePropertyBuilder.create(Datatypes.String, "actor_2_ethnic_code").label("Actor2EthnicCode") -// .description("The CAMEO code if the source document specifies the ethnic affiliation of Actor2").build()); -// allProperties.add( -// PrimitivePropertyBuilder.create(Datatypes.String, "actor_2_religion_1_code").label("Actor2Religion1Code") -// .description("The CAMEO code if the source document specifies the religious affiliation of Actor2") -// .build()); -// allProperties.add( -// PrimitivePropertyBuilder.create(Datatypes.String, "actor_2_religion_2_code").label("Actor2Religion2Code") -// .description("The CAMEO code if the source document specifies multiple religious affiliations of Actor2") -// .build()); -// allProperties -// .add(PrimitivePropertyBuilder.create(Datatypes.String, "actor_2_type_1_code").label("Actor2Type1Code") -// .description("The 3-character CAMEO code of the CAMEO “type” or “role” of Actor2").build()); -// allProperties -// .add(PrimitivePropertyBuilder.create(Datatypes.String, "actor_2_type_2_code").label("Actor2Type2Code") -// .description("The 3-character CAMEO code of the CAMEO “type” or “role” of Actor2").build()); -// allProperties -// .add(PrimitivePropertyBuilder.create(Datatypes.String, "actor_2_type_3_code").label("Actor2Type3Code") -// .description("The 3-character CAMEO code of the CAMEO “type” or “role” of Actor2").build()); -// -// allProperties.add(PrimitivePropertyBuilder.create(Datatypes.String, "source_url").label("URL") -// .description("The url of the source of the article").build()); -// -// eventSchema.setEventProperties(allProperties); -// guessSchema.setEventSchema(eventSchema); -// return guessSchema; -// } -// -// @Override -// public String getId() { -// return ID; -// } -//} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudAdapter.java deleted file mode 100644 index 98741f1dd..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudAdapter.java +++ /dev/null @@ -1,51 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ -package org.apache.streampipes.connect.adapters.iex; - - -//public abstract class IexCloudAdapter extends PullAdapter { -// -// protected static final String IEX_CLOUD_BASE_URL = "https://cloud.iexapis.com/stable/stock/";; -// protected static final String TOKEN = "?token="; -// -// protected static final String TOKEN_KEY = "token"; -// protected static final String STOCK_SYMBOL_KEY = "stock-symbol"; -// -// protected String apiToken; -// protected String stockQuote; -// private String iexCloudInstanceUrl; -// -// -// public IexCloudAdapter(SpecificAdapterStreamDescription adapterDescription, String restPath) { -// super(adapterDescription); -// ParameterExtractor extractor = new ParameterExtractor(adapterDescription.getConfig()); -// this.apiToken = extractor.secretValue(TOKEN_KEY); -// this.stockQuote = extractor.singleValue(STOCK_SYMBOL_KEY); -// this.iexCloudInstanceUrl = IEX_CLOUD_BASE_URL + stockQuote + restPath + TOKEN + apiToken; -// -// } -// -// public IexCloudAdapter() { -// super(); -// } -// -// protected <T> T fetchResult(Class<T> classToParse) throws IOException { -// String response = Request.Get(iexCloudInstanceUrl).execute().returnContent().asString(); -// return new Gson().fromJson(response, classToParse); -// } -//} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudNewsAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudNewsAdapter.java deleted file mode 100644 index a742fe3be..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudNewsAdapter.java +++ /dev/null @@ -1,119 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.iex; - -//public class IexCloudNewsAdapter extends IexCloudAdapter { -// -// public static final String ID = "org.apache.streampipes.connect.adapters.iex.news"; -// -// private static final String News = "/news"; -// -// private static final String Timestamp = "timestamp"; -// private static final String Headline = "headline"; -// private static final String Source = "source"; -// private static final String Url = "url"; -// private static final String Summary = "summary"; -// private static final String Related = "related"; -// private static final String Image = "image"; -// private static final String Lang = "lang"; -// private static final String HasPaywall = "hasPaywall"; -// -// public IexCloudNewsAdapter(SpecificAdapterStreamDescription adapterStreamDescription) { -// super(adapterStreamDescription, News); -// } -// -// public IexCloudNewsAdapter() { -// super(); -// } -// -// @Override -// protected void pullData() { -// try { -// IexNewsData[] rawModel = fetchResult(IexNewsData[].class); -// -// for (IexNewsData newsData : rawModel) { -// Map<String, Object> outMap = new HashMap<>(); -// outMap.put(Timestamp, newsData.getDatetime()); -// outMap.put(Headline, newsData.getHeadline()); -// outMap.put(Source, newsData.getSource()); -// outMap.put(Url, newsData.getUrl()); -// outMap.put(Summary, newsData.getSummary()); -// outMap.put(Related, newsData.getRelated()); -// outMap.put(Image, newsData.getImage()); -// outMap.put(Lang, newsData.getLang()); -// outMap.put(HasPaywall, newsData.getHasPaywall()); -// -// adapterPipeline.process(outMap); -// } -// } catch (IOException e) { -// e.printStackTrace(); -// } -// } -// -// @Override -// protected PollingSettings getPollingInterval() { -// return PollingSettings.from(TimeUnit.SECONDS, 60); -// } -// -// @Override -// public SpecificAdapterStreamDescription declareModel() { -// return SpecificDataStreamAdapterBuilder.create(ID) -// .withAssets(Assets.DOCUMENTATION, Assets.ICON) -// .withLocales(Locales.EN) -// .category(AdapterType.Finance, AdapterType.News) -// .requiredSecret(Labels.withId(TOKEN_KEY)) -// .requiredTextParameter(Labels.withId(STOCK_SYMBOL_KEY)) -// .build(); -// } -// -// @Override -// public Adapter getInstance(SpecificAdapterStreamDescription adapterDescription) { -// return new IexCloudNewsAdapter(adapterDescription); -// } -// -// @Override -// public GuessSchema getSchema(SpecificAdapterStreamDescription adapterDescription) -// throws AdapterException, ParseException { -// return GuessSchemaBuilder.create() -// .property(EpProperties.timestampProperty(Timestamp)) -// .property(EpProperties.stringEp(Labels.from("headline", "Headline", -// "The headline of the article"), Headline, SO.TEXT)) -// .property(EpProperties.stringEp(Labels.from("source", "Source", -// "The source of the article"), Source, SO.TEXT)) -// .property(EpProperties.stringEp(Labels.from("url", "URL", -// "The URL of the article"), Url, SO.CONTENT_URL)) -// .property(EpProperties.stringEp(Labels.from("summary", "Summary", -// "A short summary of the article"), Summary, SO.TEXT)) -// .property(EpProperties.stringEp(Labels.from("related", "Related", -// "A comma-separated list of related stock symbols"), Related, SO.TEXT)) -// .property(EpProperties.stringEp(Labels.from("image", "Image", -// "Link to an image related to the news article"), Image, SO.IMAGE)) -// .property(EpProperties.stringEp(Labels.from("lang", "Language", -// "The language the article is writte in"), Lang, SO.IN_LANGUAGE)) -// .property(EpProperties.stringEp(Labels.from("paywall", "Has Paywall", -// "Indicates whether the article is behind a paywall"), HasPaywall, -// SO.TEXT)) -// .build(); -// } -// -// @Override -// public String getId() { -// return ID; -// } -//} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudStockAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudStockAdapter.java deleted file mode 100644 index e15ae1176..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudStockAdapter.java +++ /dev/null @@ -1,92 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.iex; - -//public class IexCloudStockAdapter extends IexCloudAdapter { -// -// public static final String ID = "org.apache.streampipes.connect.adapters.iex.stocks"; -// -// private static final String Quotes = "/quote"; -// private static final String LatestUpdate = "latestUpdate"; -// private static final String LatestPrice = "latestPrice"; -// private static final String Symbol = "symbol"; -// -// public IexCloudStockAdapter(SpecificAdapterStreamDescription adapterDescription) { -// super(adapterDescription, Quotes); -// } -// -// public IexCloudStockAdapter() { -// super(); -// } -// -// @Override -// public SpecificAdapterStreamDescription declareModel() { -// return SpecificDataStreamAdapterBuilder.create(ID) -// .withAssets(Assets.DOCUMENTATION, Assets.ICON) -// .withLocales(Locales.EN) -// .category(AdapterType.Finance) -// .requiredSecret(Labels.withId(TOKEN_KEY)) -// .requiredTextParameter(Labels.withId(STOCK_SYMBOL_KEY)) -// .build(); -// -// } -// -// @Override -// protected void pullData() { -// try { -// IexStockData rawModel = fetchResult(IexStockData.class); -// -// Map<String, Object> outMap = new HashMap<>(); -// outMap.put(LatestUpdate, rawModel.getLatestUpdate()); -// outMap.put(Symbol, rawModel.getSymbol()); -// outMap.put(LatestPrice, rawModel.getLatestPrice()); -// -// adapterPipeline.process(outMap); -// } catch (IOException e) { -// e.printStackTrace(); -// } -// } -// -// @Override -// protected PollingSettings getPollingInterval() { -// return PollingSettings.from(TimeUnit.SECONDS, 5); -// } -// -// @Override -// public Adapter getInstance(SpecificAdapterStreamDescription adapterDescription) { -// return new IexCloudStockAdapter(adapterDescription); -// } -// -// @Override -// public GuessSchema getSchema(SpecificAdapterStreamDescription adapterDescription) -// throws AdapterException, ParseException { -// return GuessSchemaBuilder.create() -// .property(EpProperties.timestampProperty(LatestUpdate)) -// .property(EpProperties.stringEp(Labels.from("symbol", "Symbol", -// "The stock symbol"), Symbol, SO.TEXT)) -// .property(EpProperties.doubleEp(Labels.from("latest-price", "Latest price", -// "The latest stock price"), LatestPrice, SO.NUMBER)) -// .build(); -// } -// -// @Override -// public String getId() { -// return ID; -// } -//} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/model/IexNewsData.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/model/IexNewsData.java deleted file mode 100644 index 375a212e7..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/model/IexNewsData.java +++ /dev/null @@ -1,120 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.iex.model; - -import com.google.gson.annotations.SerializedName; - -import jakarta.annotation.Generated; - -@Generated("net.hexar.json2pojo") -@SuppressWarnings("unused") -public class IexNewsData { - - @SerializedName("datetime") - private Long mDatetime; - @SerializedName("hasPaywall") - private Boolean mHasPaywall; - @SerializedName("headline") - private String mHeadline; - @SerializedName("image") - private String mImage; - @SerializedName("lang") - private String mLang; - @SerializedName("related") - private String mRelated; - @SerializedName("source") - private String mSource; - @SerializedName("summary") - private String mSummary; - @SerializedName("url") - private String mUrl; - - public Long getDatetime() { - return mDatetime; - } - - public void setDatetime(Long datetime) { - mDatetime = datetime; - } - - public Boolean getHasPaywall() { - return mHasPaywall; - } - - public void setHasPaywall(Boolean hasPaywall) { - mHasPaywall = hasPaywall; - } - - public String getHeadline() { - return mHeadline; - } - - public void setHeadline(String headline) { - mHeadline = headline; - } - - public String getImage() { - return mImage; - } - - public void setImage(String image) { - mImage = image; - } - - public String getLang() { - return mLang; - } - - public void setLang(String lang) { - mLang = lang; - } - - public String getRelated() { - return mRelated; - } - - public void setRelated(String related) { - mRelated = related; - } - - public String getSource() { - return mSource; - } - - public void setSource(String source) { - mSource = source; - } - - public String getSummary() { - return mSummary; - } - - public void setSummary(String summary) { - mSummary = summary; - } - - public String getUrl() { - return mUrl; - } - - public void setUrl(String url) { - mUrl = url; - } - -} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/model/IexStockData.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/model/IexStockData.java deleted file mode 100644 index 0e05d0067..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iex/model/IexStockData.java +++ /dev/null @@ -1,410 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.iex.model; - -import com.google.gson.annotations.SerializedName; - -import jakarta.annotation.Generated; - -@Generated("net.hexar.json2pojo") -@SuppressWarnings("unused") -public class IexStockData { - - @SerializedName("avgTotalVolume") - private Long mAvgTotalVolume; - @SerializedName("calculationPrice") - private String mCalculationPrice; - @SerializedName("change") - private Double mChange; - @SerializedName("changePercent") - private Double mChangePercent; - @SerializedName("close") - private Double mClose; - @SerializedName("closeTime") - private Long mCloseTime; - @SerializedName("companyName") - private String mCompanyName; - @SerializedName("delayedPrice") - private Double mDelayedPrice; - @SerializedName("delayedPriceTime") - private Long mDelayedPriceTime; - @SerializedName("extendedChange") - private Double mExtendedChange; - @SerializedName("extendedChangePercent") - private Double mExtendedChangePercent; - @SerializedName("extendedPrice") - private Double mExtendedPrice; - @SerializedName("extendedPriceTime") - private Long mExtendedPriceTime; - @SerializedName("high") - private Double mHigh; - @SerializedName("iexAskPrice") - private Long mIexAskPrice; - @SerializedName("iexAskSize") - private Long mIexAskSize; - @SerializedName("iexBidPrice") - private Long mIexBidPrice; - @SerializedName("iexBidSize") - private Long mIexBidSize; - @SerializedName("iexLastUpdated") - private Long mIexLastUpdated; - @SerializedName("iexMarketPercent") - private Double mIexMarketPercent; - @SerializedName("iexRealtimePrice") - private Double mIexRealtimePrice; - @SerializedName("iexRealtimeSize") - private Long mIexRealtimeSize; - @SerializedName("iexVolume") - private Long mIexVolume; - @SerializedName("latestPrice") - private Double mLatestPrice; - @SerializedName("latestSource") - private String mLatestSource; - @SerializedName("latestTime") - private String mLatestTime; - @SerializedName("latestUpdate") - private Long mLatestUpdate; - @SerializedName("latestVolume") - private Long mLatestVolume; - @SerializedName("low") - private Double mLow; - @SerializedName("marketCap") - private Long mMarketCap; - @SerializedName("open") - private Double mOpen; - @SerializedName("openTime") - private Long mOpenTime; - @SerializedName("peRatio") - private Double mPeRatio; - @SerializedName("previousClose") - private Double mPreviousClose; - @SerializedName("symbol") - private String mSymbol; - @SerializedName("week52High") - private Double mWeek52High; - @SerializedName("week52Low") - private Long mWeek52Low; - @SerializedName("ytdChange") - private Double mYtdChange; - - public Long getAvgTotalVolume() { - return mAvgTotalVolume; - } - - public void setAvgTotalVolume(Long avgTotalVolume) { - mAvgTotalVolume = avgTotalVolume; - } - - public String getCalculationPrice() { - return mCalculationPrice; - } - - public void setCalculationPrice(String calculationPrice) { - mCalculationPrice = calculationPrice; - } - - public Double getChange() { - return mChange; - } - - public void setChange(Double change) { - mChange = change; - } - - public Double getChangePercent() { - return mChangePercent; - } - - public void setChangePercent(Double changePercent) { - mChangePercent = changePercent; - } - - public Double getClose() { - return mClose; - } - - public void setClose(Double close) { - mClose = close; - } - - public Long getCloseTime() { - return mCloseTime; - } - - public void setCloseTime(Long closeTime) { - mCloseTime = closeTime; - } - - public String getCompanyName() { - return mCompanyName; - } - - public void setCompanyName(String companyName) { - mCompanyName = companyName; - } - - public Double getDelayedPrice() { - return mDelayedPrice; - } - - public void setDelayedPrice(Double delayedPrice) { - mDelayedPrice = delayedPrice; - } - - public Long getDelayedPriceTime() { - return mDelayedPriceTime; - } - - public void setDelayedPriceTime(Long delayedPriceTime) { - mDelayedPriceTime = delayedPriceTime; - } - - public Double getExtendedChange() { - return mExtendedChange; - } - - public void setExtendedChange(Double extendedChange) { - mExtendedChange = extendedChange; - } - - public Double getExtendedChangePercent() { - return mExtendedChangePercent; - } - - public void setExtendedChangePercent(Double extendedChangePercent) { - mExtendedChangePercent = extendedChangePercent; - } - - public Double getExtendedPrice() { - return mExtendedPrice; - } - - public void setExtendedPrice(Double extendedPrice) { - mExtendedPrice = extendedPrice; - } - - public Long getExtendedPriceTime() { - return mExtendedPriceTime; - } - - public void setExtendedPriceTime(Long extendedPriceTime) { - mExtendedPriceTime = extendedPriceTime; - } - - public Double getHigh() { - return mHigh; - } - - public void setHigh(Double high) { - mHigh = high; - } - - public Long getIexAskPrice() { - return mIexAskPrice; - } - - public void setIexAskPrice(Long iexAskPrice) { - mIexAskPrice = iexAskPrice; - } - - public Long getIexAskSize() { - return mIexAskSize; - } - - public void setIexAskSize(Long iexAskSize) { - mIexAskSize = iexAskSize; - } - - public Long getIexBidPrice() { - return mIexBidPrice; - } - - public void setIexBidPrice(Long iexBidPrice) { - mIexBidPrice = iexBidPrice; - } - - public Long getIexBidSize() { - return mIexBidSize; - } - - public void setIexBidSize(Long iexBidSize) { - mIexBidSize = iexBidSize; - } - - public Long getIexLastUpdated() { - return mIexLastUpdated; - } - - public void setIexLastUpdated(Long iexLastUpdated) { - mIexLastUpdated = iexLastUpdated; - } - - public Double getIexMarketPercent() { - return mIexMarketPercent; - } - - public void setIexMarketPercent(Double iexMarketPercent) { - mIexMarketPercent = iexMarketPercent; - } - - public Double getIexRealtimePrice() { - return mIexRealtimePrice; - } - - public void setIexRealtimePrice(Double iexRealtimePrice) { - mIexRealtimePrice = iexRealtimePrice; - } - - public Long getIexRealtimeSize() { - return mIexRealtimeSize; - } - - public void setIexRealtimeSize(Long iexRealtimeSize) { - mIexRealtimeSize = iexRealtimeSize; - } - - public Long getIexVolume() { - return mIexVolume; - } - - public void setIexVolume(Long iexVolume) { - mIexVolume = iexVolume; - } - - public Double getLatestPrice() { - return mLatestPrice; - } - - public void setLatestPrice(Double latestPrice) { - mLatestPrice = latestPrice; - } - - public String getLatestSource() { - return mLatestSource; - } - - public void setLatestSource(String latestSource) { - mLatestSource = latestSource; - } - - public String getLatestTime() { - return mLatestTime; - } - - public void setLatestTime(String latestTime) { - mLatestTime = latestTime; - } - - public Long getLatestUpdate() { - return mLatestUpdate; - } - - public void setLatestUpdate(Long latestUpdate) { - mLatestUpdate = latestUpdate; - } - - public Long getLatestVolume() { - return mLatestVolume; - } - - public void setLatestVolume(Long latestVolume) { - mLatestVolume = latestVolume; - } - - public Double getLow() { - return mLow; - } - - public void setLow(Double low) { - mLow = low; - } - - public Long getMarketCap() { - return mMarketCap; - } - - public void setMarketCap(Long marketCap) { - mMarketCap = marketCap; - } - - public Double getOpen() { - return mOpen; - } - - public void setOpen(Double open) { - mOpen = open; - } - - public Long getOpenTime() { - return mOpenTime; - } - - public void setOpenTime(Long openTime) { - mOpenTime = openTime; - } - - public Double getPeRatio() { - return mPeRatio; - } - - public void setPeRatio(Double peRatio) { - mPeRatio = peRatio; - } - - public Double getPreviousClose() { - return mPreviousClose; - } - - public void setPreviousClose(Double previousClose) { - mPreviousClose = previousClose; - } - - public String getSymbol() { - return mSymbol; - } - - public void setSymbol(String symbol) { - mSymbol = symbol; - } - - public Double getWeek52High() { - return mWeek52High; - } - - public void setWeek52High(Double week52High) { - mWeek52High = week52High; - } - - public Long getWeek52Low() { - return mWeek52Low; - } - - public void setWeek52Low(Long week52Low) { - mWeek52Low = week52Low; - } - - public Double getYtdChange() { - return mYtdChange; - } - - public void setYtdChange(Double ytdChange) { - mYtdChange = ytdChange; - } - -} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/OpenSenseMapAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/OpenSenseMapAdapter.java deleted file mode 100644 index 6fb9b300a..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/OpenSenseMapAdapter.java +++ /dev/null @@ -1,374 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.sensemap; - -//public class OpenSenseMapAdapter extends PullRestAdapter { -// -// private Logger logger = LoggerFactory.getLogger(OpenSenseMapAdapter.class); -// -// public static final String ID = "org.apache.streampipes.connect.adapters.sensemap"; -// public static final int POLLING_INTERVALL = 5; -// -// private List<String> selectedSensors; -// -// private String standartKeys[] = {"id", "timestamp", "model", "latitude", "longitude"}; -// -// // private String url = "https://api.opensensemap.org/boxes";; -// private String url = "http://localhost:3001/opensensemap";; -//// private String url = "http://test-connect-datasources-rest:3001/opensensemap";; -// -// -// public OpenSenseMapAdapter() { -// super(); -// } -// -// public OpenSenseMapAdapter(SpecificAdapterStreamDescription adapterDescription) { -// super(adapterDescription); -// -// -// } -// -// @Override -// public SpecificAdapterStreamDescription declareModel() { -// -// SpecificAdapterStreamDescription description = -// SpecificDataStreamAdapterBuilder.create(ID, "OpenSenseMap", "Environment Sensors") -// .iconUrl("openSenseMap.png") -// .category(AdapterType.Environment, AdapterType.OpenData) -// .requiredMultiValueSelection(Labels.from("sensors", "Sensors", -// "Select the sensors that are included in the data stream"), Stream -// .of(SensorNames.ALL_SENSOR_LABELS) -// .map(s -> new Option(s, SensorNames.getKeyFromLabel(s))) -// .collect(Collectors.toList())) -// .build(); -// -// description.setAppId(ID); -// return description; -// } -// -// @Override -// public Adapter getInstance(SpecificAdapterStreamDescription adapterDescription) { -// return new OpenSenseMapAdapter(adapterDescription); -// } -// -// @Override -// public GuessSchema getSchema(SpecificAdapterStreamDescription adapterDescription) { -// GuessSchema guessSchema = new GuessSchema(); -// -// EventSchema eventSchema = new EventSchema(); -// EventPropertyPrimitive eventPropertyPrimitive = new EventPropertyPrimitive(); -// eventPropertyPrimitive.setRuntimeType(XSD.DOUBLE.toString()); -// -// List<EventProperty> allProperties = new ArrayList<>(); -// -// List<Option> allOptions = ((AnyStaticProperty) (adapterDescription.getConfig().get(0))).getOptions(); -// activateSensors(allOptions); -// -// // Set basic properties -// allProperties.add(EpProperties.timestampProperty(SensorNames.KEY_TIMESTAMP)); -// allProperties.add( -// PrimitivePropertyBuilder -// .create(Datatypes.Integer, SensorNames.KEY_ID) -// .label(SensorNames.LABEL_ID) -// .description("The unique identifier of a SenseBox") -// .build()); -// allProperties.add( -// PrimitivePropertyBuilder -// .create(Datatypes.String, SensorNames.KEY_NAME) -// .label(SensorNames.LABEL_NAME) -// .description("The name of the SenseBox") -// .build()); -// allProperties.add( -// PrimitivePropertyBuilder -// .create(Datatypes.String, SensorNames.KEY_MODEL) -// .label(SensorNames.LABEL_MODEL) -// .description("Model of the SenseBox") -// .build()); -// -// allProperties.add( -// PrimitivePropertyBuilder -// .create(Datatypes.String, SensorNames.KEY_LATITUDE) -// .label(SensorNames.LABEL_LATITUDE) -// .description("Latitude value of box location") -// .build()); -// allProperties.add( -// PrimitivePropertyBuilder -// .create(Datatypes.String, SensorNames.KEY_LONGITUDE) -// .label(SensorNames.LABEL_LONGITUDE) -// .description("Longitude value of box location") -// .build()); -// -// -// if (selected(SensorNames.KEY_TEMPERATURE)) { -// allProperties.add(PrimitivePropertyBuilder -// .create(Datatypes.Double, SensorNames.KEY_TEMPERATURE) -// .label(SensorNames.LABEL_TEMPERATURE) -// .description("Measurement for the temperature") -//// .measurementUnit(TemperatureUnit.CELSIUS.getResource()) -// .build()); -// } -// if (selected(SensorNames.KEY_HUMIDITY)) { -// allProperties.add(PrimitivePropertyBuilder -// .create(Datatypes.Double, SensorNames.KEY_HUMIDITY) -// .label(SensorNames.LABEL_HUMIDITY) -// .description("Measures the humidity in the air") -//// .measurementUnit(CountingUnit.PERCENT.getResource()) -// .build()); -// } -// if (selected(SensorNames.KEY_PRESSURE)) { -// allProperties.add(PrimitivePropertyBuilder -// .create(Datatypes.Double, SensorNames.KEY_PRESSURE) -// .label(SensorNames.LABEL_PRESSURE) -// .description("Air pressure") -//// .measurementUnit(PressureOrStressUnit.PASCAL.getResource()) -// .build()); -// } -// if (selected(SensorNames.KEY_ILLUMINANCE)) { -// allProperties.add(PrimitivePropertyBuilder -// .create(Datatypes.Double, SensorNames.KEY_ILLUMINANCE) -// .label(SensorNames.LABEL_ILLUMINANCE) -// .description("Total luminous flux incident on a surface per unit area") -// // TODO -//// .measurementUnit(.getResource()) -// .build()); -// } -// if (selected(SensorNames.KEY_UV_INTENSITY)) { -// allProperties.add(PrimitivePropertyBuilder -// .create(Datatypes.Double, SensorNames.KEY_UV_INTENSITY) -// .label(SensorNames.LABEL_UV_INTENSITY) -// .description("") -// // TODO -//// .measurementUnit(.getResource()) -// .build()); -// } -// if (selected(SensorNames.KEY_PM10)) { -// allProperties.add(PrimitivePropertyBuilder -// .create(Datatypes.Double, SensorNames.KEY_PM10) -// .label(SensorNames.LABEL_PM10) -// .description("Particulate Matter in the air with a diameter of 10 micrometer") -// // TODO -//// .measurementUnit(.getResource()) -// .build()); -// } -// if (selected(SensorNames.KEY_PM2_5)) { -// allProperties.add(PrimitivePropertyBuilder -// .create(Datatypes.Double, SensorNames.KEY_PM2_5) -// .label(SensorNames.LABEL_PM2_5) -// .description("Particulate Matter in the air with a diameter of 10 micrometer") -// // TODO -//// .measurementUnit(.getResource()) -// .build()); -// } -// -// eventSchema.setEventProperties(allProperties); -// guessSchema.setEventSchema(eventSchema); -// return guessSchema; -// } -// -// @Override -// public String getId() { -// return ID; -// } -// -// public List<Map<String, Object>> getEvents() { -// -// List<Map<String, Object>> eventResults = new ArrayList<>(); -// -// SenseBox[] senseBoxResult = {}; -// try { -// senseBoxResult = getDataFromEndpoint(url, SenseBox[].class); -// } catch (AdapterException e) { -// e.printStackTrace(); -// } -// -// logger.info("Number of all detected SenseBoxes: " + senseBoxResult.length); -// -// for (SenseBox senseBox : senseBoxResult) { -// Map<String, Object> event = new HashMap<>(); -// -// if (senseBox.getCreatedAt() != null) { -// -// event.put(SensorNames.KEY_ID, senseBox.get_id()); -// // TODO change timestamp -// Long timestamp = getDateMillis(senseBox.getUpdatedAt()); -// event.put(SensorNames.KEY_TIMESTAMP, timestamp); -// event.put(SensorNames.KEY_NAME, senseBox.getName()); -// event.put(SensorNames.KEY_MODEL, senseBox.getModel()); -// -// double latitude = getLatitude(senseBox); -// double longitude = getLongitude(senseBox); -// if (latitude != Double.MIN_VALUE && longitude != Double.MIN_VALUE) { -// event.put(SensorNames.KEY_LATITUDE, getLatitude(senseBox)); -// event.put(SensorNames.KEY_LONGITUDE, getLongitude(senseBox)); -// } else { -// logger -// .info("Sense box id: " + senseBox.get_id() + " does not contain correct latitude or longitude values"); -// } -// -//// Add Sensor values -// for (Sensor s : senseBox.getSensors()) { -// if (s.getLastMeasurement() != null) { -// String key = SensorNames.getKey(s.getTitle()); -// if (key != SensorNames.KEY_NOT_FOUND) { -// double value = getDoubleSensorValue(s.getLastMeasurement().getValue()); -// if (value != Double.MIN_VALUE) { -// event.put(key, value); -// } else { -// logger.info("Sensor value " + s.getLastMeasurement().getValue() + " of sensor id: " -// + s.get_id() + " in sense box id: " + senseBox.get_id() -// + " is not correctly formatted"); -// } -// } -// } -// } -// -// if (checkEvent(event)) { -// eventResults.add(filterSensors(event)); -// } -// } -// } -// -// logger.info("All data sucessfully processed and " + eventResults.size() + " events will be send to Kafka"); -// -// return eventResults; -// } -// -// @Override -// protected void pullData() { -// List<Option> allOptions = ((AnyStaticProperty) (adapterDescription.getConfig().get(0))).getOptions(); -// activateSensors(allOptions); -// -// List<Map<String, Object>> events = getEvents(); -// -// for (Map<String, Object> event : events) { -// adapterPipeline.process(event); -// } -// -// } -// -// @Override -// protected PollingSettings getPollingInterval() { -// return PollingSettings.from(TimeUnit.MINUTES, POLLING_INTERVALL); -// } -// -// private void activateSensors(List<Option> config) { -//// this.selectedSensors = Arrays.asList(SensorNames.ALL_SENSOR_KEYS); -// this.selectedSensors = new ArrayList<>(); -// -// for (Option option : config) { -// -// if (option.isSelected()) { -// this.selectedSensors.add(option.getInternalName()); -// } -// } -// } -// -// private Map<String, Object> filterSensors(Map<String, Object> event) { -// Map<String, Object> result = new HashMap<>(); -// -// for (String key : selectedSensors) { -// result.put(key, event.get(key)); -// } -// -// for (String key : SensorNames.ALL_META_KEYS) { -// result.put(key, event.get(key)); -// } -// -// return result; -// } -// -// private boolean checkEvent(Map<String, Object> event) { -// for (String key : selectedSensors) { -// if (!event.keySet().contains(key)) { -// return false; -// } -// } -// -// for (String key : SensorNames.ALL_META_KEYS) { -// if (!event.keySet().contains(key)) { -// return false; -// } -// } -// -// return true; -// } -// -// private boolean selected(String value) { -// return this.selectedSensors.contains(value); -// } -// -// public void setUrl(String url) { -// this.url = url; -// } -// -// public void setSelectedSensors(List<String> selectedSensors) { -// this.selectedSensors = selectedSensors; -// } -// -// private Long getDateMillis(String date) { -// -// if (date != null) { -// Date result = Date.from(Instant.parse(date)); -// return result.getTime(); -// } -// return Long.MIN_VALUE; -// } -// -// private double getDoubleSensorValue(String sensorValue) { -// try { -// return Double.parseDouble(sensorValue); -// } catch (NumberFormatException e) { -// return Double.MIN_VALUE; -// } -// } -// -// private double getLatitude(SenseBox box) { -// List<Double> latlong = getLatLong(box); -// -// if (latlong != null) { -// return latlong.get(1); -// } else { -// return Double.MIN_VALUE; -// } -// -// } -// -// private double getLongitude(SenseBox box) { -// List<Double> latlong = getLatLong(box); -// -// if (latlong != null) { -// return latlong.get(0); -// } else { -// return Double.MIN_VALUE; -// } -// } -// -// private List<Double> getLatLong(SenseBox box) { -// CurrentLocation currentLocation = box.getCurrentLocation(); -// -// if (currentLocation == null) { -// return null; -// } -// -// List<Double> latlong = currentLocation.getCoordinates(); -// -// return latlong; -// -// } -//} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/SensorNames.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/SensorNames.java deleted file mode 100644 index e3dffbada..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/SensorNames.java +++ /dev/null @@ -1,136 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.sensemap; - -import java.util.Arrays; -import java.util.List; - -public class SensorNames { - public static final String KEY_NOT_FOUND = "KEY_NOT_FOUND"; - - public static final String KEY_ID = "id"; - public static final String KEY_TIMESTAMP = "timestamp"; - public static final String KEY_NAME = "name"; - public static final String KEY_MODEL = "model"; - public static final String KEY_LATITUDE = "latitude"; - public static final String KEY_LONGITUDE = "longitude"; - - - public static final String KEY_TEMPERATURE = "temperature"; - public static final String KEY_HUMIDITY = "humidity"; - public static final String KEY_PRESSURE = "pressure"; - public static final String KEY_ILLUMINANCE = "illuminance"; - public static final String KEY_UV_INTENSITY = "uv_intensity"; - public static final String KEY_PM10 = "pm10"; - public static final String KEY_PM2_5 = "pm2_5"; - - - public static final String LABEL_ID = "Id"; - public static final String LABEL_NAME = "Name"; - public static final String LABEL_MODEL = "Model"; - public static final String LABEL_LATITUDE = "latitude"; - public static final String LABEL_LONGITUDE = "longitude"; - - - public static final String LABEL_TEMPERATURE = "Temperature"; - public static final String LABEL_HUMIDITY = "Humidity"; - public static final String LABEL_PRESSURE = "Pressure"; - public static final String LABEL_ILLUMINANCE = "Illuminance"; - public static final String LABEL_UV_INTENSITY = "UV Intensity"; - public static final String LABEL_PM10 = "Particulate Matter 10"; - public static final String LABEL_PM2_5 = "Particulate Matter 2.5"; - - - public static final String GERMAN_TEMPERATURE = "Temperatur"; - public static final String GERMAN_HUMIDITY = "rel. Luftfeuchte"; - public static final String GERMAN_PRESSURE = "Luftdruck"; - public static final String GERMAN_ILLUMINANCE = "Beleuchtungsstärke"; - public static final String GERMAN_UV_INTENSITY = "UV-Intensität"; - public static final String GERMAN_PM10 = "PM10"; - public static final String GERMAN_PM2_5 = "PM2.5"; - - public static final String[] ALL_SENSOR_KEYS = { - KEY_TEMPERATURE, - KEY_HUMIDITY, - KEY_PRESSURE, - KEY_ILLUMINANCE, - KEY_UV_INTENSITY, - KEY_PM10, - KEY_PM2_5 - }; - - public static final String[] ALL_SENSOR_LABELS = { - LABEL_TEMPERATURE, - LABEL_HUMIDITY, - LABEL_PRESSURE, - LABEL_ILLUMINANCE, - LABEL_UV_INTENSITY, - LABEL_PM10, - LABEL_PM2_5 - }; - public static final List<String> ALL_META_KEYS = Arrays.asList( - KEY_ID, KEY_NAME, KEY_TIMESTAMP, KEY_MODEL, KEY_LONGITUDE, KEY_LATITUDE - ); - - public static String getKey(String germanKeyValue) { - if (check(germanKeyValue, GERMAN_TEMPERATURE)) { - return KEY_TEMPERATURE; - } else if (check(germanKeyValue, GERMAN_HUMIDITY)) { - return KEY_HUMIDITY; - } else if (check(germanKeyValue, GERMAN_PRESSURE)) { - return KEY_PRESSURE; - } else if (check(germanKeyValue, GERMAN_ILLUMINANCE)) { - return KEY_ILLUMINANCE; - } else if (check(germanKeyValue, GERMAN_UV_INTENSITY)) { - return KEY_UV_INTENSITY; - } else if (check(germanKeyValue, GERMAN_PM10)) { - return KEY_PM10; - } else if (check(germanKeyValue, GERMAN_PM2_5)) { - return KEY_PM2_5; - } else { - return KEY_NOT_FOUND; - } - } - - public static String getKeyFromLabel(String labelString) { - if (LABEL_TEMPERATURE.equals(labelString)) { - return KEY_TEMPERATURE; - } else if (LABEL_HUMIDITY.equals(labelString)) { - return KEY_HUMIDITY; - } else if (LABEL_PRESSURE.equals(labelString)) { - return KEY_PRESSURE; - } else if (LABEL_ILLUMINANCE.equals(labelString)) { - return KEY_ILLUMINANCE; - } else if (LABEL_UV_INTENSITY.equals(labelString)) { - return KEY_UV_INTENSITY; - } else if (LABEL_PM10.equals(labelString)) { - return KEY_PM10; - } else if (LABEL_PM2_5.equals(labelString)) { - return KEY_PM2_5; - } else { - return KEY_NOT_FOUND; - } - } - - private static boolean check(String value, String contains) { - return value.contains(contains); - } - - -} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/CurrentLocation.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/CurrentLocation.java deleted file mode 100644 index d0c8a29a4..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/CurrentLocation.java +++ /dev/null @@ -1,62 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.sensemap.model; - -import com.google.gson.annotations.SerializedName; - -import jakarta.annotation.Generated; - -import java.util.List; - -@Generated("net.hexar.json2pojo") -@SuppressWarnings("unused") -public class CurrentLocation { - - @SerializedName("coordinates") - private List<Double> mCoordinates; - @SerializedName("timestamp") - private String mTimestamp; - @SerializedName("type") - private String mType; - - public List<Double> getCoordinates() { - return mCoordinates; - } - - public void setCoordinates(List<Double> coordinates) { - mCoordinates = coordinates; - } - - public String getTimestamp() { - return mTimestamp; - } - - public void setTimestamp(String timestamp) { - mTimestamp = timestamp; - } - - public String getType() { - return mType; - } - - public void setType(String type) { - mType = type; - } - -} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Geometry.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Geometry.java deleted file mode 100644 index 68f06b4b3..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Geometry.java +++ /dev/null @@ -1,62 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.sensemap.model; - -import com.google.gson.annotations.SerializedName; - -import jakarta.annotation.Generated; - -import java.util.List; - -@Generated("net.hexar.json2pojo") -@SuppressWarnings("unused") -public class Geometry { - - @SerializedName("coordinates") - private List<Double> mCoordinates; - @SerializedName("timestamp") - private String mTimestamp; - @SerializedName("type") - private String mType; - - public List<Double> getCoordinates() { - return mCoordinates; - } - - public void setCoordinates(List<Double> coordinates) { - mCoordinates = coordinates; - } - - public String getTimestamp() { - return mTimestamp; - } - - public void setTimestamp(String timestamp) { - mTimestamp = timestamp; - } - - public String getType() { - return mType; - } - - public void setType(String type) { - mType = type; - } - -} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/LastMeasurement.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/LastMeasurement.java deleted file mode 100644 index 68250497e..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/LastMeasurement.java +++ /dev/null @@ -1,50 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.sensemap.model; - -import com.google.gson.annotations.SerializedName; - -import jakarta.annotation.Generated; - -@Generated("net.hexar.json2pojo") -@SuppressWarnings("unused") -public class LastMeasurement { - - @SerializedName("createdAt") - private String mCreatedAt; - @SerializedName("value") - private String mValue; - - public String getCreatedAt() { - return mCreatedAt; - } - - public void setCreatedAt(String createdAt) { - mCreatedAt = createdAt; - } - - public String getValue() { - return mValue; - } - - public void setValue(String value) { - mValue = value; - } - -} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Loc.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Loc.java deleted file mode 100644 index daaecf152..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Loc.java +++ /dev/null @@ -1,50 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.sensemap.model; - -import com.google.gson.annotations.SerializedName; - -import jakarta.annotation.Generated; - -@Generated("net.hexar.json2pojo") -@SuppressWarnings("unused") -public class Loc { - - @SerializedName("geometry") - private Geometry mGeometry; - @SerializedName("type") - private String mType; - - public Geometry getGeometry() { - return mGeometry; - } - - public void setGeometry(Geometry geometry) { - mGeometry = geometry; - } - - public String getType() { - return mType; - } - - public void setType(String type) { - mType = type; - } - -} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/SenseBox.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/SenseBox.java deleted file mode 100644 index 7b6081cd6..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/SenseBox.java +++ /dev/null @@ -1,122 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.sensemap.model; - -import com.google.gson.annotations.SerializedName; - -import jakarta.annotation.Generated; - -import java.util.List; - -@Generated("net.hexar.json2pojo") -@SuppressWarnings("unused") -public class SenseBox { - - @SerializedName("createdAt") - private String mCreatedAt; - @SerializedName("currentLocation") - private CurrentLocation mCurrentLocation; - @SerializedName("exposure") - private String mExposure; - @SerializedName("loc") - private List<Loc> mLoc; - @SerializedName("model") - private String mModel; - @SerializedName("name") - private String mName; - @SerializedName("sensors") - private List<Sensor> mSensors; - @SerializedName("updatedAt") - private String mUpdatedAt; - @SerializedName("_id") - private String mId; - - public String getCreatedAt() { - return mCreatedAt; - } - - public void setCreatedAt(String createdAt) { - mCreatedAt = createdAt; - } - - public CurrentLocation getCurrentLocation() { - return mCurrentLocation; - } - - public void setCurrentLocation(CurrentLocation currentLocation) { - mCurrentLocation = currentLocation; - } - - public String getExposure() { - return mExposure; - } - - public void setExposure(String exposure) { - mExposure = exposure; - } - - public List<Loc> getLoc() { - return mLoc; - } - - public void setLoc(List<Loc> loc) { - mLoc = loc; - } - - public String getModel() { - return mModel; - } - - public void setModel(String model) { - mModel = model; - } - - public String getName() { - return mName; - } - - public void setName(String name) { - mName = name; - } - - public List<Sensor> getSensors() { - return mSensors; - } - - public void setSensors(List<Sensor> sensors) { - mSensors = sensors; - } - - public String getUpdatedAt() { - return mUpdatedAt; - } - - public void setUpdatedAt(String updatedAt) { - mUpdatedAt = updatedAt; - } - - public String get_id() { - return mId; - } - - public void set_id(String id) { - mId = id; - } - -} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Sensor.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Sensor.java deleted file mode 100644 index c70a88aac..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Sensor.java +++ /dev/null @@ -1,90 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You 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. - * - */ - -package org.apache.streampipes.connect.adapters.sensemap.model; - -import com.google.gson.annotations.SerializedName; - -import jakarta.annotation.Generated; - -@Generated("net.hexar.json2pojo") -@SuppressWarnings("unused") -public class Sensor { - - @SerializedName("icon") - private String mIcon; - @SerializedName("lastMeasurement") - private LastMeasurement mLastMeasurement; - @SerializedName("sensorType") - private String mSensorType; - @SerializedName("title") - private String mTitle; - @SerializedName("unit") - private String mUnit; - @SerializedName("_id") - private String mId; - - public String getIcon() { - return mIcon; - } - - public void setIcon(String icon) { - mIcon = icon; - } - - public LastMeasurement getLastMeasurement() { - return mLastMeasurement; - } - - public void setLastMeasurement(LastMeasurement lastMeasurement) { - mLastMeasurement = lastMeasurement; - } - - public String getSensorType() { - return mSensorType; - } - - public void setSensorType(String sensorType) { - mSensorType = sensorType; - } - - public String getTitle() { - return mTitle; - } - - public void setTitle(String title) { - mTitle = title; - } - - public String getUnit() { - return mUnit; - } - - public void setUnit(String unit) { - mUnit = unit; - } - - public String get_id() { - return mId; - } - - public void set_id(String id) { - mId = id; - } - -} diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackAdapter.java index a2457d464..f88e562e5 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackAdapter.java @@ -35,6 +35,7 @@ import org.apache.streampipes.vocabulary.SO; import static org.apache.streampipes.sdk.helpers.EpProperties.stringEp; import static org.apache.streampipes.sdk.helpers.EpProperties.timestampProperty; +@Deprecated(since = "0.93.0", forRemoval = true) public class SlackAdapter implements StreamPipesAdapter { public static final String ID = "org.apache.streampipes.connect.adapters.slack"; diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackConsumer.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackConsumer.java index bc8d7a589..b553eca4d 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackConsumer.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackConsumer.java @@ -28,6 +28,7 @@ import java.io.IOException; import java.util.HashMap; import java.util.Map; +@Deprecated(since = "0.93.0", forRemoval = true) public class SlackConsumer implements Runnable { private final IEventCollector collector; diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/ti/TISensorTag.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/ti/TISensorTag.java index 9f944c262..8cc6002fc 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/ti/TISensorTag.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/ti/TISensorTag.java @@ -45,6 +45,7 @@ import static org.apache.streampipes.sdk.helpers.EpProperties.booleanEp; import static org.apache.streampipes.sdk.helpers.EpProperties.doubleEp; import static org.apache.streampipes.sdk.helpers.EpProperties.timestampProperty; +@Deprecated(since = "0.93.0", forRemoval = true) public class TISensorTag implements StreamPipesAdapter { public static final String ID = "org.apache.streampipes.connect.adapters.ti"; diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaAdapter.java index 8760987c1..c1d158b72 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaAdapter.java @@ -35,6 +35,7 @@ import static org.apache.streampipes.sdk.helpers.EpProperties.longEp; import static org.apache.streampipes.sdk.helpers.EpProperties.stringEp; import static org.apache.streampipes.sdk.helpers.EpProperties.timestampProperty; +@Deprecated(since = "0.93.0", forRemoval = true) public abstract class WikipediaAdapter implements StreamPipesAdapter { public static final String TIMESTAMP = "timestamp"; diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaEditedArticlesAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaEditedArticlesAdapter.java index d41157b36..eedfebca4 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaEditedArticlesAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaEditedArticlesAdapter.java @@ -23,6 +23,7 @@ import org.apache.streampipes.sdk.builder.adapter.AdapterConfigurationBuilder; import org.apache.streampipes.sdk.helpers.Locales; import org.apache.streampipes.sdk.utils.Assets; +@Deprecated(since = "0.93.0", forRemoval = true) public class WikipediaEditedArticlesAdapter extends WikipediaAdapter { public static final String ID = "org.apache.streampipes.connect.adapters.wikipedia.edit"; diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaModelConverter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaModelConverter.java index 62755b886..1ddcfd617 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaModelConverter.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaModelConverter.java @@ -39,6 +39,7 @@ import static org.apache.streampipes.connect.adapters.wikipedia.WikipediaAdapter import static org.apache.streampipes.connect.adapters.wikipedia.WikipediaAdapter.USER; import static org.apache.streampipes.connect.adapters.wikipedia.WikipediaAdapter.WIKI; +@Deprecated(since = "0.93.0", forRemoval = true) public class WikipediaModelConverter { private final WikipediaModel wikipediaModel; diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaNewArticlesAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaNewArticlesAdapter.java index 8067a7936..99d40fe30 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaNewArticlesAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaNewArticlesAdapter.java @@ -23,6 +23,7 @@ import org.apache.streampipes.sdk.builder.adapter.AdapterConfigurationBuilder; import org.apache.streampipes.sdk.helpers.Locales; import org.apache.streampipes.sdk.utils.Assets; +@Deprecated(since = "0.93.0", forRemoval = true) public class WikipediaNewArticlesAdapter extends WikipediaAdapter { public static final String ID = "org.apache.streampipes.connect.adapters.wikipedia.new"; diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaSseConsumer.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaSseConsumer.java index 992dd767b..75ecf4cc6 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaSseConsumer.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaSseConsumer.java @@ -27,6 +27,7 @@ import jakarta.ws.rs.client.Client; import jakarta.ws.rs.client.ClientBuilder; import jakarta.ws.rs.client.WebTarget; +@Deprecated(since = "0.93.0", forRemoval = true) public class WikipediaSseConsumer { private Boolean running = true; diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Length.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Length.java index 671fa4c3f..8eb33284b 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Length.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Length.java @@ -24,6 +24,7 @@ import jakarta.annotation.Generated; @Generated("net.hexar.json2pojo") @SuppressWarnings("unused") +@Deprecated(since = "0.93.0", forRemoval = true) public class Length { @SerializedName("new") diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Meta.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Meta.java index 289cb3f56..7f626cb5d 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Meta.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Meta.java @@ -24,6 +24,7 @@ import jakarta.annotation.Generated; @Generated("net.hexar.json2pojo") @SuppressWarnings("unused") +@Deprecated(since = "0.93.0", forRemoval = true) public class Meta { @SerializedName("domain") diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Revision.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Revision.java index afdf357b0..42647a77f 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Revision.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Revision.java @@ -24,6 +24,7 @@ import jakarta.annotation.Generated; @Generated("net.hexar.json2pojo") @SuppressWarnings("unused") +@Deprecated(since = "0.93.0", forRemoval = true) public class Revision { @SerializedName("new") diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/WikipediaModel.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/WikipediaModel.java index 4dc0810b3..ac925315a 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/WikipediaModel.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/WikipediaModel.java @@ -24,6 +24,7 @@ import jakarta.annotation.Generated; @Generated("net.hexar.json2pojo") @SuppressWarnings("unused") +@Deprecated(since = "0.93.0", forRemoval = true) public class WikipediaModel { @SerializedName("bot") diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/documentation.md b/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/documentation.md deleted file mode 100644 index 85c0788e5..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/documentation.md +++ /dev/null @@ -1,36 +0,0 @@ -<!-- - ~ Licensed to the Apache Software Foundation (ASF) under one or more - ~ contributor license agreements. See the NOTICE file distributed with - ~ this work for additional information regarding copyright ownership. - ~ The ASF licenses this file to You 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. - ~ - --> - -## GDELT - Global Database of Society - -<p align="center"> - <img src="icon.png" width="150px;" class="pe-image-documentation"/> -</p> - -*** - -## Description -This adapter provides news events from the GDELT API. - -## Configuration - -(no futher configuration required) - - -*** - diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/icon.png b/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/icon.png deleted file mode 100644 index b9ec80c3c..000000000 Binary files a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/icon.png and /dev/null differ diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/strings.en b/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/strings.en deleted file mode 100644 index 84f35253d..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.gdelt/strings.en +++ /dev/null @@ -1,21 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You 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. -# - -org.apache.streampipes.connect.adapters.gdelt.title=GDELT -org.apache.streampipes.connect.adapters.gdelt.description=Global Database of Society - - diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/documentation.md b/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/documentation.md deleted file mode 100644 index 6c61c7bc2..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/documentation.md +++ /dev/null @@ -1,42 +0,0 @@ -<!-- - ~ Licensed to the Apache Software Foundation (ASF) under one or more - ~ contributor license agreements. See the NOTICE file distributed with - ~ this work for additional information regarding copyright ownership. - ~ The ASF licenses this file to You 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. - ~ - --> - -## IEX Cloud News - -<p align="center"> - <img src="icon.png" width="150px;" class="pe-image-documentation"/> -</p> - -*** - -## Description -This adapter provides news events from the IEXCloud news API. An API key from IEXCloud is required. -Visit <a href='https://iexcloud.io'>IEX Cloud</a> for more info. - -*** - -## Configuration - - -### API Token -A valid API token from the IEXCloud API. - -### Stock Symbol -A stock symbol that should be monitored. - - diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/icon.png b/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/icon.png deleted file mode 100644 index 48afa81c2..000000000 Binary files a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/icon.png and /dev/null differ diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/strings.en b/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/strings.en deleted file mode 100644 index 9f2e68c9d..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.news/strings.en +++ /dev/null @@ -1,25 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You 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. -# - -org.apache.streampipes.connect.adapters.iex.news.title=IEX Cloud News -org.apache.streampipes.connect.adapters.iex.news.description=Fetches news for a given company (10 news / minutes maximum) - -token.title=API Token -token.description=The IEXCloud API token - -stock-symbol.title=Stock Symbol -stock-symbol.description=The stock symbol (e.g., AAPL) diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/documentation.md b/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/documentation.md deleted file mode 100644 index 7add22fca..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/documentation.md +++ /dev/null @@ -1,41 +0,0 @@ -<!-- - ~ Licensed to the Apache Software Foundation (ASF) under one or more - ~ contributor license agreements. See the NOTICE file distributed with - ~ this work for additional information regarding copyright ownership. - ~ The ASF licenses this file to You 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. - ~ - --> - -## IEX Cloud Stock Quotes - -<p align="center"> - <img src="icon.png" width="150px;" class="pe-image-documentation"/> -</p> - -*** - -## Description -This adapter provides news events from the IEXCloud news API. An API key from IEXCloud is required. -Visit <a href='https://iexcloud.io'>IEX Cloud</a> for more info. - -*** - -## Configuration - - -### API Token -A valid API token from the IEXCloud API. - -### Stock Symbol -A stock symbol that should be monitored. - diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/icon.png b/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/icon.png deleted file mode 100644 index 48afa81c2..000000000 Binary files a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/icon.png and /dev/null differ diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/strings.en b/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/strings.en deleted file mode 100644 index ab1dc7459..000000000 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.iex.stocks/strings.en +++ /dev/null @@ -1,25 +0,0 @@ -# -# Licensed to the Apache Software Foundation (ASF) under one or more -# contributor license agreements. See the NOTICE file distributed with -# this work for additional information regarding copyright ownership. -# The ASF licenses this file to You 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. -# - -org.apache.streampipes.connect.adapters.iex.stocks.title=IEX Cloud Stock Quotes -org.apache.streampipes.connect.adapters.iex.stocks.description=Live stock data provided by the IEXCloud API - -token.title=API Token -token.description=The IEXCloud API token - -stock-symbol.title=Stock Symbol -stock-symbol.description=The stock symbol (e.g., AAPL)
