Hello world

conf/serviceConfig/helloworld.xml

@@ -0,0 +1,13 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<service xmlns="http://zstack.org/schema/zstack">
+    <id>helloworld</id>
+    <interceptor>HelloWorldApiInterceptor</interceptor>
+
+    <message>
+        <name>org.zstack.plugin.example.APIHelloWorldMsg</name>
+    </message>
+
+    <message>
+        <name>org.zstack.plugin.example.APICreateGreetingMsg</name>
+    </message>
+</service>

conf/springConfigXml/helloworld.xml

@@ -0,0 +1,27 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop"
+       xmlns:tx="http://www.springframework.org/schema/tx" xmlns:zstack="http://zstack.org/schema/zstack"
+       xsi:schemaLocation="http://www.springframework.org/schema/beans
+    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
+    http://www.springframework.org/schema/aop
+    http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
+    http://www.springframework.org/schema/tx
+    http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
+    http://zstack.org/schema/zstack
+    http://zstack.org/schema/zstack/plugin.xsd"
+       default-init-method="init" default-destroy-method="destroy">
+
+    <bean id="HelloWorldManager" class="org.zstack.plugin.example.HelloWorldManagerImpl" >
+        <zstack:plugin>
+            <zstack:extension interface="org.zstack.header.Component" />
+            <zstack:extension interface="org.zstack.header.Service" />
+        </zstack:plugin>
+    </bean>
+
+    <bean id="HelloWorldApiInterceptor" class="org.zstack.plugin.example.HelloWorldApiInterceptor" >
+        <zstack:plugin>
+            <zstack:extension interface="org.zstack.header.apimediator.ApiMessageInterceptor"/>
+        </zstack:plugin>
+    </bean>
+</beans>

conf/zstack.xml

@@ -119,4 +119,5 @@
     <import resource="springConfigXml/sugonSdnController.xml"/>
     <import resource="springConfigXml/TfPortAllocator.xml"/>
     <import resource="springConfigXml/HostNetworkManager.xml"/>
+    <import resource="springConfigXml/helloworld.xml"/>
 </beans>

plugin/helloworld/pom.xml

@@ -0,0 +1,77 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>plugin</artifactId>
+        <groupId>org.zstack</groupId>
+        <version>4.10.0</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>helloworld</artifactId>
+
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>${project.compiler.version}</version>
+                <configuration>
+                    <compilerId>groovy-eclipse-compiler</compilerId>
+                    <source>${project.java.version}</source>
+                    <target>${project.java.version}</target>
+                    <debuglevel>lines,vars,source</debuglevel>
+                    <debug>true</debug>
+                </configuration>
+                <dependencies>
+                    <dependency>
+                        <groupId>org.codehaus.groovy</groupId>
+                        <artifactId>groovy-eclipse-compiler</artifactId>
+                        <version>${groovy.eclipse.compiler}</version>
+                    </dependency>
+                    <dependency>
+                        <groupId>org.codehaus.groovy</groupId>
+                        <artifactId>groovy-eclipse-batch</artifactId>
+                        <version>${groovy.eclipse.batch}</version>
+                    </dependency>
+                </dependencies>
+            </plugin>
+            <plugin>
+                <groupId>org.codehaus.mojo</groupId>
+                <artifactId>aspectj-maven-plugin</artifactId>
+                <version>${aspectj.plugin.version}</version>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>compile</goal>
+                            <goal>test-compile</goal>
+                        </goals>
+                    </execution>
+                </executions>
+                <configuration>
+                    <source>${project.java.version}</source>
+                    <target>${project.java.version}</target>
+                    <complianceLevel>${project.java.version}</complianceLevel>
+                    <XnoInline>true</XnoInline>
+                    <aspectLibraries>
+                        <aspectLibrary>
+                            <groupId>org.springframework</groupId>
+                            <artifactId>spring-aspects</artifactId>
+                        </aspectLibrary>
+                        <aspectLibrary>
+                            <groupId>org.zstack</groupId>
+                            <artifactId>core</artifactId>
+                        </aspectLibrary>
+                        <aspectLibrary>
+                            <groupId>org.zstack</groupId>
+                            <artifactId>header</artifactId>
+                        </aspectLibrary>
+                    </aspectLibraries>
+                </configuration>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

plugin/helloworld/src/main/java/org/zstack/plugin/example/APICreateGreetingEvent.java

@@ -0,0 +1,24 @@
+package org.zstack.plugin.example;
+
+import org.zstack.header.message.APIEvent;
+import org.zstack.header.rest.RestResponse;
+
+@RestResponse(allTo = "inventory")
+public class APICreateGreetingEvent extends APIEvent {
+    private GreetingInventory inventory;
+
+    public APICreateGreetingEvent() {
+    }
+
+    public APICreateGreetingEvent(String apiId) {
+        super(apiId);
+    }
+
+    public GreetingInventory getInventory() {
+        return inventory;
+    }
+
+    public void setInventory(GreetingInventory inventory) {
+        this.inventory = inventory;
+    }
+}

plugin/helloworld/src/main/java/org/zstack/plugin/example/APICreateGreetingMsg.java

@@ -0,0 +1,21 @@
+package org.zstack.plugin.example;
+
+import org.springframework.http.HttpMethod;
+import org.zstack.header.message.APICreateMessage;
+import org.zstack.header.message.APIParam;
+import org.zstack.header.rest.RestRequest;
+
+
+@RestRequest(path = "/helloworld/greetings", method = HttpMethod.POST, responseClass = APICreateGreetingEvent.class, parameterName = "params")
+public class APICreateGreetingMsg extends APICreateMessage {
+    @APIParam(emptyString = false)
+    private String greeting;
+
+    public String getGreeting() {
+        return greeting;
+    }
+
+    public void setGreeting(String greeting) {
+        this.greeting = greeting;
+    }
+}

plugin/helloworld/src/main/java/org/zstack/plugin/example/APIDeleteGreetingEvent.java

@@ -0,0 +1,14 @@
+package org.zstack.plugin.example;
+
+import org.zstack.header.message.APIEvent;
+import org.zstack.header.rest.RestResponse;
+
+@RestResponse
+public class APIDeleteGreetingEvent extends APIEvent {
+    public APIDeleteGreetingEvent() {
+    }
+
+    public APIDeleteGreetingEvent(String apiId) {
+        super(apiId);
+    }
+}

plugin/helloworld/src/main/java/org/zstack/plugin/example/APIDeleteGreetingMsg.java

@@ -0,0 +1,23 @@
+package org.zstack.plugin.example;
+
+import org.springframework.http.HttpMethod;
+import org.zstack.header.message.APIDeleteMessage;
+import org.zstack.header.rest.RestRequest;
+
+@RestRequest(path = "/helloworld/greetings/{uuid}", method = HttpMethod.DELETE, responseClass = APIDeleteGreetingEvent.class)
+public class APIDeleteGreetingMsg extends APIDeleteMessage implements GreetingMessage {
+    private String uuid;
+
+    public String getUuid() {
+        return uuid;
+    }
+
+    public void setUuid(String uuid) {
+        this.uuid = uuid;
+    }
+
+    @Override
+    public String getGreetingUuid() {
+        return uuid;
+    }
+}

plugin/helloworld/src/main/java/org/zstack/plugin/example/APIHelloWorldEvent.java

@@ -0,0 +1,24 @@
+package org.zstack.plugin.example;
+
+import org.zstack.header.message.APIEvent;
+import org.zstack.header.rest.RestResponse;
+
+@RestResponse(allTo = "greeting")
+public class APIHelloWorldEvent extends APIEvent {
+    private String greeting;
+
+    public APIHelloWorldEvent() {
+    }
+
+    public APIHelloWorldEvent(String apiId) {
+        super(apiId);
+    }
+
+    public String getGreeting() {
+        return greeting;
+    }
+
+    public void setGreeting(String greeting) {
+        this.greeting = greeting;
+    }
+}

plugin/helloworld/src/main/java/org/zstack/plugin/example/APIHelloWorldMsg.java

@@ -0,0 +1,20 @@
+package org.zstack.plugin.example;
+
+import org.springframework.http.HttpMethod;
+import org.zstack.header.message.APIMessage;
+import org.zstack.header.message.APIParam;
+import org.zstack.header.rest.RestRequest;
+
+@RestRequest(path = "/helloworld/greetings", method = HttpMethod.POST, responseClass = APIHelloWorldEvent.class)
+public class APIHelloWorldMsg extends APIMessage {
+    @APIParam(maxLength = 255)
+    private String greeting;
+
+    public String getGreeting() {
+        return greeting;
+    }
+
+    public void setGreeting(String greeting) {
+        this.greeting = greeting;
+    }
+}

plugin/helloworld/src/main/java/org/zstack/plugin/example/Greeting.java

@@ -0,0 +1,7 @@
+package org.zstack.plugin.example;
+
+import org.zstack.header.message.Message;
+
+public interface Greeting {
+    void handleMessage(Message msg);
+}

plugin/helloworld/src/main/java/org/zstack/plugin/example/GreetingBase.java

@@ -0,0 +1,50 @@
+package org.zstack.plugin.example;
+
+import org.springframework.beans.factory.annotation.Autowire;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Configurable;
+import org.zstack.core.cloudbus.CloudBus;
+import org.zstack.core.db.DatabaseFacade;
+import org.zstack.header.message.APIMessage;
+import org.zstack.header.message.Message;
+
+@Configurable(preConstruction = true, autowire = Autowire.BY_TYPE)
+public class GreetingBase implements Greeting {
+    protected GreetingVO self;
+
+    @Autowired
+    protected CloudBus bus;
+    @Autowired
+    protected DatabaseFacade dbf;
+
+    public GreetingBase(GreetingVO self) {
+        this.self = self;
+    }
+
+    @Override
+    public void handleMessage(Message msg) {
+        if (msg instanceof APIMessage) {
+            handleApiMessage((APIMessage) msg);
+        } else {
+            handleLocalMessage(msg);
+        }
+    }
+
+    private void handleLocalMessage(Message msg) {
+        bus.dealWithUnknownMessage(msg);
+    }
+
+    private void handleApiMessage(APIMessage msg) {
+        if (msg instanceof APIDeleteGreetingMsg) {
+            handle((APIDeleteGreetingMsg) msg);
+        } else {
+            bus.dealWithUnknownMessage(msg);
+        }
+    }
+
+    private void handle(APIDeleteGreetingMsg msg) {
+        dbf.remove(self);
+
+        bus.publish(new APIDeleteGreetingEvent(msg.getId()));
+    }
+}

plugin/helloworld/src/main/java/org/zstack/plugin/example/GreetingInventory.java

@@ -0,0 +1,61 @@
+package org.zstack.plugin.example;
+
+import org.zstack.header.search.Inventory;
+
+import java.sql.Timestamp;
+import java.util.Collection;
+import java.util.List;
+import java.util.stream.Collectors;
+
+@Inventory(mappingVOClass = GreetingVO.class)
+public class GreetingInventory {
+    private String uuid;
+    private String greeting;
+    private Timestamp lastOpDate;
+    private Timestamp createDate;
+
+    public static GreetingInventory valueOf(GreetingVO vo) {
+        GreetingInventory inv = new GreetingInventory();
+        inv.uuid = vo.getUuid();
+        inv.greeting = vo.getGreeting();
+        inv.lastOpDate = vo.getLastOpDate();
+        inv.createDate = vo.getCreateDate();
+        return inv;
+    }
+
+    public static List<GreetingInventory> valueOf(Collection<GreetingVO> vos) {
+        return vos.stream().map(GreetingInventory::valueOf).collect(Collectors.toList());
+    }
+
+    public String getUuid() {
+        return uuid;
+    }
+
+    public void setUuid(String uuid) {
+        this.uuid = uuid;
+    }
+
+    public String getGreeting() {
+        return greeting;
+    }
+
+    public void setGreeting(String greeting) {
+        this.greeting = greeting;
+    }
+
+    public Timestamp getLastOpDate() {
+        return lastOpDate;
+    }
+
+    public void setLastOpDate(Timestamp lastOpDate) {
+        this.lastOpDate = lastOpDate;
+    }
+
+    public Timestamp getCreateDate() {
+        return createDate;
+    }
+
+    public void setCreateDate(Timestamp createDate) {
+        this.createDate = createDate;
+    }
+}

plugin/helloworld/src/main/java/org/zstack/plugin/example/GreetingMessage.java

@@ -0,0 +1,5 @@
+package org.zstack.plugin.example;
+
+public interface GreetingMessage {
+    String getGreetingUuid();
+}