add coap网络组件

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/CoordinateResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 固件更新进程
- * @createTime 2021年12月16日 16:24:00
- */
-public class CoordinateResource extends AbstractCoapResource {
-
-    public CoordinateResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/coordinate"));
-    }
-
-    public CoordinateResource(EmitterProcessor<CoapExchangeMessage> processor, boolean visible) {
-        super(processor, String.format(prefixTopicName,"/coordinate"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/DirectResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 固件更新进程
- * @createTime 2021年12月16日 16:24:00
- */
-public class DirectResource extends AbstractCoapResource {
-
-    public DirectResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/direct"));
-    }
-
-    public DirectResource(EmitterProcessor<CoapExchangeMessage> processor, boolean visible) {
-        super(processor, String.format(prefixTopicName,"/direct"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/EventCoapResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 事件上报资源
- * @createTime 2021年12月16日 16:24:00
- */
-public class EventCoapResource extends AbstractCoapResource {
-
-    public EventCoapResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/event/{eventId}"));
-    }
-
-    public EventCoapResource(EmitterProcessor<CoapExchangeMessage> processor,  boolean visible) {
-        super(processor,  String.format(prefixTopicName,"/event/{eventId}"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/FirmwareReportResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 固件更新进程
- * @createTime 2021年12月16日 16:24:00
- */
-public class FirmwareReportResource extends AbstractCoapResource {
-
-    public FirmwareReportResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/firmware/report"));
-    }
-
-    public FirmwareReportResource(EmitterProcessor<CoapExchangeMessage> processor, boolean visible) {
-        super(processor, String.format(prefixTopicName,"/firmware/report"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/LogResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 固件更新进程
- * @createTime 2021年12月16日 16:24:00
- */
-public class LogResource extends AbstractCoapResource {
-
-    public LogResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/log"));
-    }
-
-    public LogResource(EmitterProcessor<CoapExchangeMessage> processor, boolean visible) {
-        super(processor, String.format(prefixTopicName,"/log"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/MetadataDerivedCoapResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 事件上报资源
- * @createTime 2021年12月16日 16:24:00
- */
-public class MetadataDerivedCoapResource extends AbstractCoapResource {
-
-    public MetadataDerivedCoapResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/metadata/derived"));
-    }
-
-    public MetadataDerivedCoapResource(EmitterProcessor<CoapExchangeMessage> processor, boolean visible) {
-        super(processor,  String.format(prefixTopicName,"/metadata/derived"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/PropertiesReportCoapResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 事件上报资源
- * @createTime 2021年12月16日 16:24:00
- */
-public class PropertiesReportCoapResource extends AbstractCoapResource {
-
-    public PropertiesReportCoapResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/properties/report"));
-    }
-
-    public PropertiesReportCoapResource(EmitterProcessor<CoapExchangeMessage> processor, boolean visible) {
-        super(processor,  String.format(prefixTopicName,"/properties/report"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/RegisterCoapResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 子设备注册
- * @createTime 2021年12月16日 16:24:00
- */
-public class RegisterCoapResource extends AbstractCoapResource {
-
-    public RegisterCoapResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/child/{childDeviceId}/register"));
-    }
-
-    public RegisterCoapResource(EmitterProcessor<CoapExchangeMessage> processor, boolean visible) {
-        super(processor, String.format(prefixTopicName,"/child/{childDeviceId}/register"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/TagResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 固件更新进程
- * @createTime 2021年12月16日 16:24:00
- */
-public class TagResource extends AbstractCoapResource {
-
-    public TagResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/tag"));
-    }
-
-    public TagResource(EmitterProcessor<CoapExchangeMessage> processor, boolean visible) {
-        super(processor, String.format(prefixTopicName,"/tag"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/TimeSyncResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 固件更新进程
- * @createTime 2021年12月16日 16:24:00
- */
-public class TimeSyncResource extends AbstractCoapResource {
-
-    public TimeSyncResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/time-sync"));
-    }
-
-    public TimeSyncResource(EmitterProcessor<CoapExchangeMessage> processor, boolean visible) {
-        super(processor, String.format(prefixTopicName,"/time-sync"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/UnRegisterCoapResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 子设备注销
- * @createTime 2021年12月16日 16:24:00
- */
-public class UnRegisterCoapResource extends AbstractCoapResource {
-
-    public UnRegisterCoapResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/child/{childDeviceId}/unregister"));
-    }
-
-    public UnRegisterCoapResource(EmitterProcessor<CoapExchangeMessage> processor,boolean visible) {
-        super(processor, String.format(prefixTopicName,"/child/{childDeviceId}/unregister"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/UpgradeProgressResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 固件更新进程
- * @createTime 2021年12月16日 16:24:00
- */
-public class UpgradeProgressResource extends AbstractCoapResource {
-
-    public UpgradeProgressResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/firmware/upgrade/progress"));
-    }
-
-    public UpgradeProgressResource(EmitterProcessor<CoapExchangeMessage> processor, boolean visible) {
-        super(processor, String.format(prefixTopicName,"/firmware/upgrade/progress"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/resources/UpgradePullResource.java

@@ -1,23 +0,0 @@
-package org.jetlinks.community.network.coap.resources;
-
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName EventResouce.java
- * @Description 固件更新进程
- * @createTime 2021年12月16日 16:24:00
- */
-public class UpgradePullResource extends AbstractCoapResource {
-
-    public UpgradePullResource(EmitterProcessor<CoapExchangeMessage> processor) {
-        super(processor, String.format(prefixTopicName,"/firmware/pull"));
-    }
-
-    public UpgradePullResource(EmitterProcessor<CoapExchangeMessage> processor, boolean visible) {
-        super(processor, String.format(prefixTopicName,"/firmware/pull"), visible);
-    }
-
-}

jetlinks-components/network-component/coap-component/src/main/java/org/jetlinks/community/network/coap/server/DefaultCoapResource.java

@@ -1,34 +0,0 @@
-package org.jetlinks.community.network.coap.server;
-
-import org.eclipse.californium.core.CoapResource;
-import org.eclipse.californium.core.server.resources.CoapExchange;
-import org.jetlinks.core.message.codec.coap.CoapExchangeMessage;
-import reactor.core.publisher.EmitterProcessor;
-
-/**
- * @author lifang
- * @version 1.0.0
- * @ClassName DefaultCoapResource.java
- * @Description  //仅支持post方法
- * @createTime 2021年12月16日 10:33:00
- */
-public class DefaultCoapResource extends CoapResource {
-
-    private EmitterProcessor<CoapExchangeMessage> processor;
-    public DefaultCoapResource(EmitterProcessor<CoapExchangeMessage> processor,String name) {
-        super(name);
-        this.processor=processor;
-    }
-
-    public DefaultCoapResource(String name, boolean visible) {
-        super(name, visible);
-    }
-
-
-    @Override
-    public void handlePOST(CoapExchange exchange) {
-        if(processor.hasDownstreams()){
-            processor.onNext(new CoapExchangeMessage(exchange));
-        }
-    }
-}