From 85f6a9912991f068d25b67d163d98cd8b8a186b0 Mon Sep 17 00:00:00 2001
From: pabloFuente <pablofuenteperez@gmail.com>
Date: Fri, 3 Jun 2022 14:13:36 +0200
Subject: [PATCH] openvidu-basic-java

---
 openvidu-basic-java/.gitignore                |  24 +++
 openvidu-basic-java/pom.xml                   |  52 +++++++
 .../main/java/io/openvidu/basic/java/App.java |  13 ++
 .../io/openvidu/basic/java/Controller.java    |  72 +++++++++
 .../java/io/openvidu/basic/java/Utils.java    | 146 ++++++++++++++++++
 .../src/main/resources/application.properties |   9 ++
 .../main/resources/openvidu-selfsigned.jks    | Bin 0 -> 2268 bytes
 .../java/io/openvidu/basic/java/AppTests.java |  13 ++
 8 files changed, 329 insertions(+)
 create mode 100644 openvidu-basic-java/.gitignore
 create mode 100644 openvidu-basic-java/pom.xml
 create mode 100644 openvidu-basic-java/src/main/java/io/openvidu/basic/java/App.java
 create mode 100644 openvidu-basic-java/src/main/java/io/openvidu/basic/java/Controller.java
 create mode 100644 openvidu-basic-java/src/main/java/io/openvidu/basic/java/Utils.java
 create mode 100644 openvidu-basic-java/src/main/resources/application.properties
 create mode 100644 openvidu-basic-java/src/main/resources/openvidu-selfsigned.jks
 create mode 100644 openvidu-basic-java/src/test/java/io/openvidu/basic/java/AppTests.java

diff --git a/openvidu-basic-java/.gitignore b/openvidu-basic-java/.gitignore
new file mode 100644
index 00000000..950fc085
--- /dev/null
+++ b/openvidu-basic-java/.gitignore
@@ -0,0 +1,24 @@
+# Compiled class file
+*.class
+
+# Log file
+*.log
+
+# BlueJ files
+*.ctxt
+
+# Mobile Tools for Java (J2ME)
+.mtj.tmp/
+
+# Package Files #
+*.jar
+*.war
+*.ear
+*.zip
+*.tar.gz
+*.rar
+
+# virtual machine crash logs, see http://www.java.com/en/download/help/error_hotspot.xml
+hs_err_pid*
+
+target/
diff --git a/openvidu-basic-java/pom.xml b/openvidu-basic-java/pom.xml
new file mode 100644
index 00000000..8407db05
--- /dev/null
+++ b/openvidu-basic-java/pom.xml
@@ -0,0 +1,52 @@
+<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">
+	<modelVersion>4.0.0</modelVersion>
+
+	<groupId>io.openvidu</groupId>
+	<artifactId>openvidu-basic-java</artifactId>
+	<version>2.22.0</version>
+	<packaging>jar</packaging>
+
+	<name>openvidu-basic-java</name>
+	<url>https://github.com/OpenVidu/openvidu-tutorials/tree/master/openvidu-basic-java</url>
+
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>2.7.0</version>
+	</parent>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+		<java.version>1.8</java.version>
+		<start-class>io.openvidu.basic.java.App</start-class>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>io.openvidu</groupId>
+			<artifactId>openvidu-java-client</artifactId>
+			<version>2.22.0</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+	</dependencies>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+		</plugins>
+	</build>
+
+</project>
diff --git a/openvidu-basic-java/src/main/java/io/openvidu/basic/java/App.java b/openvidu-basic-java/src/main/java/io/openvidu/basic/java/App.java
new file mode 100644
index 00000000..51d38690
--- /dev/null
+++ b/openvidu-basic-java/src/main/java/io/openvidu/basic/java/App.java
@@ -0,0 +1,13 @@
+package io.openvidu.basic.java;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class App {
+
+	public static void main(String[] args) {
+		SpringApplication.run(App.class, args);
+	}
+
+}
diff --git a/openvidu-basic-java/src/main/java/io/openvidu/basic/java/Controller.java b/openvidu-basic-java/src/main/java/io/openvidu/basic/java/Controller.java
new file mode 100644
index 00000000..f46ebd78
--- /dev/null
+++ b/openvidu-basic-java/src/main/java/io/openvidu/basic/java/Controller.java
@@ -0,0 +1,72 @@
+package io.openvidu.basic.java;
+
+import java.util.Map;
+
+import javax.annotation.PostConstruct;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import io.openvidu.java.client.Connection;
+import io.openvidu.java.client.ConnectionProperties;
+import io.openvidu.java.client.OpenVidu;
+import io.openvidu.java.client.OpenViduHttpException;
+import io.openvidu.java.client.OpenViduJavaClientException;
+import io.openvidu.java.client.Session;
+import io.openvidu.java.client.SessionProperties;
+
+@RestController
+public class Controller {
+
+	@Value("${OPENVIDU_URL}")
+	private String OPENVIDU_URL;
+
+	@Value("${OPENVIDU_SECRET}")
+	private String OPENVIDU_SECRET;
+
+	private OpenVidu openvidu;
+
+	private Utils utils = new Utils();
+
+	@PostConstruct
+	public void init() {
+		this.openvidu = new OpenVidu(OPENVIDU_URL, OPENVIDU_SECRET);
+	}
+
+	/**
+	 * @param params The Session properties
+	 * @return The Session ID
+	 */
+	@PostMapping("/session")
+	public ResponseEntity<String> initializeSession(@RequestBody Map<String, Object> params)
+			throws OpenViduJavaClientException, OpenViduHttpException {
+		SessionProperties properties = utils.generateSessionProperties(params);
+		Session session = openvidu.createSession(properties);
+		return new ResponseEntity<>(session.getSessionId(), HttpStatus.OK);
+	}
+
+	/**
+	 * @param sessionId The Session in which to create the Connection
+	 * @param params    The Connection properties
+	 * @return The Token associated to the Connection
+	 */
+	@PostMapping("/session/{sessionId}/connection")
+	public ResponseEntity<String> createConnection(@PathVariable("sessionId") String sessionId,
+			@RequestBody Map<String, Object> params) throws OpenViduJavaClientException, OpenViduHttpException {
+		openvidu.fetch();
+		Session session = openvidu.getActiveSessions().stream().filter(s -> sessionId.equals(s.getSessionId()))
+				.findFirst().orElse(null);
+		if (session == null) {
+			return new ResponseEntity<>(HttpStatus.NOT_FOUND);
+		}
+		ConnectionProperties properties = utils.generateConnectionProperties(params);
+		Connection connection = session.createConnection(properties);
+		return new ResponseEntity<>(connection.getToken(), HttpStatus.OK);
+	}
+
+}
diff --git a/openvidu-basic-java/src/main/java/io/openvidu/basic/java/Utils.java b/openvidu-basic-java/src/main/java/io/openvidu/basic/java/Utils.java
new file mode 100644
index 00000000..990eb4ae
--- /dev/null
+++ b/openvidu-basic-java/src/main/java/io/openvidu/basic/java/Utils.java
@@ -0,0 +1,146 @@
+package io.openvidu.basic.java;
+
+import java.util.List;
+import java.util.Map;
+
+import io.openvidu.java.client.ConnectionProperties;
+import io.openvidu.java.client.ConnectionType;
+import io.openvidu.java.client.IceServerProperties;
+import io.openvidu.java.client.KurentoOptions;
+import io.openvidu.java.client.MediaMode;
+import io.openvidu.java.client.OpenViduRole;
+import io.openvidu.java.client.Recording.OutputMode;
+import io.openvidu.java.client.RecordingLayout;
+import io.openvidu.java.client.RecordingMode;
+import io.openvidu.java.client.RecordingProperties;
+import io.openvidu.java.client.SessionProperties;
+import io.openvidu.java.client.VideoCodec;
+
+/**
+ * This class transforms raw REST API parameters to OpenVidu Java SDK classes
+ */
+public class Utils {
+
+	public SessionProperties generateSessionProperties(Map<String, Object> params) {
+		SessionProperties.Builder builder = new SessionProperties.Builder();
+		if (params.containsKey("mediaMode")) {
+			builder.mediaMode(MediaMode.valueOf((String) params.get("mediaMode")));
+		}
+		if (params.containsKey("recordingMode")) {
+			builder.recordingMode(RecordingMode.valueOf((String) params.get("recordingMode")));
+		}
+		if (params.containsKey("customSessionId")) {
+			builder.customSessionId((String) params.get("customSessionId"));
+		}
+		if (params.containsKey("forcedVideoCodec")) {
+			builder.forcedVideoCodec(VideoCodec.valueOf((String) params.get("forcedVideoCodec")));
+		}
+		if (params.containsKey("allowTranscoding")) {
+			builder.allowTranscoding((Boolean) params.get("allowTranscoding"));
+		}
+		if (params.containsKey("defaultRecordingProperties")) {
+			RecordingProperties.Builder defaultRecordingProperties = new RecordingProperties.Builder();
+			Map<String, Object> recordingProperties = (Map<String, Object>) params.get("defaultRecordingProperties");
+			if (recordingProperties.containsKey("name")) {
+				defaultRecordingProperties.name((String) recordingProperties.get("name"));
+			}
+			if (recordingProperties.containsKey("hasAudio")) {
+				defaultRecordingProperties.hasAudio((boolean) recordingProperties.get("hasAudio"));
+			}
+			if (recordingProperties.containsKey("hasVideo")) {
+				defaultRecordingProperties.hasVideo((boolean) recordingProperties.get("hasVideo"));
+			}
+			if (recordingProperties.containsKey("outputMode")) {
+				defaultRecordingProperties
+						.outputMode(OutputMode.valueOf((String) recordingProperties.get("outputMode")));
+			}
+			if (recordingProperties.containsKey("recordingLayout")) {
+				defaultRecordingProperties
+						.recordingLayout(RecordingLayout.valueOf((String) recordingProperties.get("recordingLayout")));
+			}
+			if (recordingProperties.containsKey("resolution")) {
+				defaultRecordingProperties.resolution((String) recordingProperties.get("resolution"));
+			}
+			if (recordingProperties.containsKey("frameRate")) {
+				defaultRecordingProperties.frameRate((int) recordingProperties.get("frameRate"));
+			}
+			if (recordingProperties.containsKey("shmSize")) {
+				defaultRecordingProperties.shmSize((long) recordingProperties.get("shmSize"));
+			}
+			if (recordingProperties.containsKey("ignoreFailedStreams")) {
+				defaultRecordingProperties
+						.ignoreFailedStreams((boolean) recordingProperties.get("ignoreFailedStreams"));
+			}
+			if (recordingProperties.containsKey("mediaNode")) {
+				Map<String, Object> mediaNodeInfo = (Map<String, Object>) recordingProperties.get("mediaNode");
+				if (mediaNodeInfo.containsKey("id")) {
+					defaultRecordingProperties.mediaNode((String) mediaNodeInfo.get("id"));
+				}
+			}
+		}
+		return builder.build();
+	}
+
+	public ConnectionProperties generateConnectionProperties(Map<String, Object> params) {
+		ConnectionProperties.Builder builder = new ConnectionProperties.Builder();
+		if (params.containsKey("type")) {
+			builder.type(ConnectionType.valueOf((String) params.get("type")));
+		}
+		if (params.containsKey("data")) {
+			builder.data((String) params.get("data"));
+		}
+		if (params.containsKey("record")) {
+			builder.record((boolean) params.get("record"));
+		}
+		if (params.containsKey("role")) {
+			builder.role(OpenViduRole.valueOf((String) params.get("role")));
+		}
+		if (params.containsKey("rtspUri")) {
+			builder.rtspUri((String) params.get("rtspUri"));
+		}
+		if (params.containsKey("adaptativeBitrate")) {
+			builder.adaptativeBitrate((boolean) params.get("adaptativeBitrate"));
+		}
+		if (params.containsKey("onlyPlayWithSubscribers")) {
+			builder.onlyPlayWithSubscribers((boolean) params.get("onlyPlayWithSubscribers"));
+		}
+		if (params.containsKey("networkCache")) {
+			builder.networkCache((int) params.get("networkCache"));
+		}
+		if (params.containsKey("kurentoOptions")) {
+			Map<String, Object> kurentoOptions = (Map<String, Object>) params.get("kurentoOptions");
+			KurentoOptions.Builder kurentoOptionsBuilder = new KurentoOptions.Builder();
+			if (kurentoOptions.containsKey("videoMaxRecvBandwidth")) {
+				kurentoOptionsBuilder.videoMaxRecvBandwidth((int) kurentoOptions.get("videoMaxRecvBandwidth"));
+			}
+			if (kurentoOptions.containsKey("videoMinRecvBandwidth")) {
+				kurentoOptionsBuilder.videoMinRecvBandwidth((int) kurentoOptions.get("videoMinRecvBandwidth"));
+			}
+			if (kurentoOptions.containsKey("videoMaxSendBandwidth")) {
+				kurentoOptionsBuilder.videoMaxSendBandwidth((int) kurentoOptions.get("videoMaxSendBandwidth"));
+			}
+			if (kurentoOptions.containsKey("videoMinSendBandwidth")) {
+				kurentoOptionsBuilder.videoMinSendBandwidth((int) kurentoOptions.get("videoMinSendBandwidth"));
+			}
+			if (kurentoOptions.containsKey("allowedFilters")) {
+				List<String> allowedFiltersList = (List<String>) kurentoOptions.get("allowedFilters");
+				String[] allowedFiltersArray = allowedFiltersList.stream().toArray(String[]::new);
+				kurentoOptionsBuilder.allowedFilters(allowedFiltersArray);
+			}
+			builder.kurentoOptions(kurentoOptionsBuilder.build());
+		}
+		if (params.containsKey("customIceServers")) {
+			List<Map<String, String>> customIceServersList = (List<Map<String, String>>) params.get("customIceServers");
+			for (Map<String, String> iceServer : customIceServersList) {
+				IceServerProperties.Builder iceServerBuilder = new IceServerProperties.Builder();
+				iceServerBuilder.url(iceServer.get("url"));
+				iceServerBuilder.username(iceServer.get("username"));
+				iceServerBuilder.credential(iceServer.get("credential"));
+				IceServerProperties iceServerProperties = iceServerBuilder.build();
+				builder.addCustomIceServer(iceServerProperties);
+			}
+		}
+		return builder.build();
+	}
+
+}
diff --git a/openvidu-basic-java/src/main/resources/application.properties b/openvidu-basic-java/src/main/resources/application.properties
new file mode 100644
index 00000000..bcf699a8
--- /dev/null
+++ b/openvidu-basic-java/src/main/resources/application.properties
@@ -0,0 +1,9 @@
+server.port: 5000
+server.ssl.enabled: true
+server.ssl.key-store: classpath:openvidu-selfsigned.jks
+server.ssl.key-store-password: openvidu
+server.ssl.key-store-type: JKS
+server.ssl.key-alias: openvidu-selfsigned
+
+OPENVIDU_URL: https://localhost:4443/
+OPENVIDU_SECRET: MY_SECRET
diff --git a/openvidu-basic-java/src/main/resources/openvidu-selfsigned.jks b/openvidu-basic-java/src/main/resources/openvidu-selfsigned.jks
new file mode 100644
index 0000000000000000000000000000000000000000..4a02ecc47be43f930bf2f9af4d4068880670f853
GIT binary patch
literal 2268
zcmcIlX*kr47N7r^#m-nGOPCnT=sz@)CHrd&35_I^Wt1#aSteVr#*!`jR+sE?Np>Za
ztd)!{CD{_$$<hpBT)oe|_jy0uulK|G@H@Zrob#OJ`5op8a|Hr{Ko1T0%lOGRNIn4`
zZvI$bl9#)$$5kJa+ac$8aa$e-fxrQf3fl*{5$uWx00t;PQ2+pkz^JeV1g2J3&z*sE
zg#-ahOB%B7_>-w~dp5@+hgaGht<|kF8uw@OgQZuMwIs2dzsjGVwY#9wbl24A`Npol
zW>0F#`UJI5@@6Oz|Hq4-3D0L3@8c^mu~B&T(@UI+>S@<o=r3ZoV?tccfAhzh|49qL
zc+c~g?F=m`N&5+Q&bi(orB25d<P+MpE{~Py4cgQ@p$&IXLVU?=R~c=>7m=L{NLusJ
zcvvjqXC3^ck7WeesKqiV8#=Usb}IbUXj)bT&&1nIF-4d_TdPqAEN_IH(vmbgX?xp#
zMN!2Sp(fD2NT2&`O~qM{@E=g55Ab5<C4AJF9LeUHJ-CwcOIfCW{F16>nZ;GwM&Kad
zJqudKyZEGVg`ddO27;<|@_?0?zyLPGQmFFURxD$L=X~S4Qp}N`#NswmSVnUZYUiQa
zN5W=SKcSdlT&cJIEu_!HGZCA95jn?PI}x*ctYwDRPW#NIz<EEc3+Lbm$%e_eGiNK}
zY<E_%FWP1iwEnPHQ|XrJwNhWBSBbxlez$#Vfy&ZyJm9N=ds(j|-6n6I^L+`q-Ej81
z)vH_EJ#u~U5C&5X8<cbPRG<8hx>(#+`!iF;hUCQUu+6SEW5&GmxJ(dDeN^Dio1~J6
zhMD5VESU@;Ddja;Isq`QS~++yZ=5SNX8%%C3KWZ^vdE1$;)R*zXlObkSHmZE^qyGq
z3p2H*#+y@gLXtv;jqq&M-jCH38sq)|c`fCkow>M+U^91Bun$kox7+6W4$Goi>gR@U
zaO7}#3+&%dY{1xs378q0^dC=qWpviFCU&KS`-EP;v-LQI+)=GF9Iw+Q+;fF^CSP!a
zXc&7zTk6uTIY+SPmbWiXsK>jT)lU3ejkuPUX?1_n!#N2UfA{Q_L`Y|*xevyLZjsXa
zC9T9kg_g#(B3-{M@<&Ew3bE-*{Mggo%nqW12*`x|lShr<mjiN*E#>;^tji`3ga^F0
z8dOk~iw?P)-#aaKe=%GY9BG?Ma$R$Bj}q$@Afb1^YryX$*NO-T38CdP;>}FU`(J+Q
zGF1(!*xYs~f<_WAem(V7aE9#km~)IH#?-3#M>%S<s!F2&qv08ffh}d<GSXjSb!kVq
zE>pX0!#LV~c)56YRKc-Ki8_+Ul5Q$xNZR^RX`Wr^UhY|s(iM@#CX^(8+HMz%EO;GU
z$Csp2XJ2~v$H#2CNmTw<-vLaV&DKh1E@bcw*(@SuKu-<X=)V!f+=@&Yit!ko5mt^W
ziALSZ4m*(<KW-2Rd(NN!I7E=fuC`T^U^?d-NBq{Fm|6OL)}PzTCeo};_zBX)czU#e
zBpHQ&PdQ(!c_}q{hTWGA1W!a&nYEjbLl#Rjh^~gcye{4P54al)+@luuPiR!!IYWuN
zb^hM=(4W`kmm_i65#*5$Zbg+%BvHKixT9$3h$Ke4vTQX=LN+NHw~#i(6V4FJyO8Tf
zAF}9O>l2;4;$<7cuY*Lf>5H^(Cf1~nj~FT+9NW*HOk%hy%>TIg4DDL)Bz(SyLbk7&
z`PQ&3<AJ*4@tn6a|E=I9mN~jYMC1Kjxs!gjwS}+Px=dzIKf3tPSwxM*%)K349U}jF
z=TfzbjEPZz#D^Cnj>s&9ZFwDi<FmZOMMY*CQf+L@(zZ{-1ebdI0!@TnvUDG5aBI{{
z^ZccfaC>Ducp3s>xd&2N!a*w3GmixdK%s1qs@K|nOKGemkPE@45M>g@-~s>+I0UrE
zae!<H7CRV%A8KTS;|Ec{0V^lF4cVK7wefTIBjHdW&u=F?C#%(=2wyl9VVo2w`QJQj
zfDqq*)LHkcx3h<rvMbpeln~~^odWTyAP%o`5_if$m`mjls;K`P{vRt-0qMWDdH4xf
zr~nTHqyp?vDgZ#*y(*`bCQlv{>9THaodQTxMKEHKe#LS{6oqDXOH2>lw_Q3>oeHPE
zPVaAW;t{6GEhv1A<=Z~qRG>-Y*ItjuV5SEy2kq^--%A+aJttL#@}d_NhG%k=f2=L&
zZbkcD!<TMR28Yd`kl$#o^q{mwELd)I8FxDxsYk#+b(<GBAJhjs9h>#!|CBf%?b^P<
zUYJW|ilu4#uSn(uQ4DGjI3IV1{LzJ?Q864;#X9dzYXXbg_vRb~n!c14WfCR;12mti
zktOcSn1wf`<kh|Xhllc$-CDUPuOtFf3vQK6E(AdrKWiMZf)_?-rHTfGv8L8wM9tYP
zjIQ|<MWjPn00>Zc4zvWt5BDn04HJS1Oiy$!7Bkga44fkDG<w44v{j4@4|jY>%fOC+
zLSg?qfb(|%KMW4C0KmcDXMT8EhcgEt#7x~LM?{}rc3ZsS(Y%h$5bWLQWu@Y}R9rpc
zk*k{(=Y;x_B9^U~<Mcbxha-e9UB(6=QVkq^FT|m)Gt$<(@m^?oAT;bPyJCedWXxvp
zvEBY-XFuA<gI#0Uh$B@;d99u)Th<)dO3p>=;GehZJUCwC7_)~_QDLQPB*@+_lV;0-
z=R0`odur}#Hp_4;o<I_yvb<{urkaA@jRp*Mrb7;<mmuTP9-UWod7Ck2ska!agjxt%
zzjh?9Y<=_#itgANk2cy>=b}^-15H{OpPSy9z#!<r(-GH`39Llzt;!EK4WzES)%w0!
syXJAhBUn<z+Y9!7xa)Jbcz`b(I+XB52ljX%6u-J?N;lW1(7m?)1qNB=+W-In

literal 0
HcmV?d00001

diff --git a/openvidu-basic-java/src/test/java/io/openvidu/basic/java/AppTests.java b/openvidu-basic-java/src/test/java/io/openvidu/basic/java/AppTests.java
new file mode 100644
index 00000000..b341cf0e
--- /dev/null
+++ b/openvidu-basic-java/src/test/java/io/openvidu/basic/java/AppTests.java
@@ -0,0 +1,13 @@
+package io.openvidu.basic.java;
+
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+@SpringBootTest
+class AppTests {
+
+	@Test
+	void contextLoads() {
+	}
+
+}