files added
diff --git a/src/STOMP_Types.ttcn b/src/STOMP_Types.ttcn
new file mode 100644
index 0000000..d665073
--- /dev/null
+++ b/src/STOMP_Types.ttcn
@@ -0,0 +1,154 @@
+///////////////////////////////////////////////////////////////////////////////
+//
+// Copyright (c) 2000-2017 Ericsson Telecom AB
+//
+// All rights reserved. This program and the accompanying materials
+// are made available under the terms of the Eclipse Public License v1.0
+// which accompanies this distribution, and is available at
+// http://www.eclipse.org/legal/epl-v10.html
+///////////////////////////////////////////////////////////////////////////////
+//
+// Contributors:
+// Elemer Lelik-initial implementation
+//
+//
+
+/*
+
+https://stomp.github.io/stomp-specification-1.2.html
+
+
+Augmented BNF
+
+NULL = <US-ASCII null (octet 0)>
+LF = <US-ASCII line feed (aka newline) (octet 10)>
+CR = <US-ASCII carriage return (octet 13)>
+EOL = [CR] LF
+OCTET = <any 8-bit sequence of data>
+
+frame-stream = 1*frame
+
+frame = command EOL
+ *( header EOL )
+ EOL
+ *OCTET
+ NULL
+ *( EOL )
+
+command = client-command | server-command
+
+client-command = "SEND"
+ | "SUBSCRIBE"
+ | "UNSUBSCRIBE"
+ | "BEGIN"
+ | "COMMIT"
+ | "ABORT"
+ | "ACK"
+ | "NACK"
+ | "DISCONNECT"
+ | "CONNECT"
+ | "STOMP"
+
+server-command = "CONNECTED"
+ | "MESSAGE"
+ | "RECEIPT"
+ | "ERROR"
+
+header = header-name ":" header-value
+header-name = 1*<any OCTET except CR or LF or ":">
+header-value = *<any OCTET except CR or LF or ":">
+
+*/
+
+
+module STOMP_Types {
+
+external function enc_STOMP(in STOMPFrame frame) return charstring
+with { extension "prototype(convert) encode(TEXT)" };
+external function dec_STOMP(in charstring stream) return STOMPFrame
+with { extension "prototype(convert) decode(TEXT)" };
+
+function f_enc_stomp(in STOMPFrame frame) return octetstring
+{
+ var octetstring v_os:=char2oct(enc_STOMP(frame));
+ v_os:=substr(v_os,0,lengthof(v_os)-2)&'000D0A'O;//cut @@ and add NULL EOL;
+
+ //log("v_os :",v_os)
+ return v_os
+}
+
+function f_dec_stomp(in octetstring stream) return STOMPFrame
+{
+
+ var STOMPFrame v_frame;
+ var octetstring v_os;
+ var integer v_l:=lengthof(stream);
+
+ for(var integer i:=v_l-1;i>=0;i:=i-1)
+
+ {
+
+ if(stream[i]=='00'O) {
+ v_os:=substr(stream,0,i)&'4040'O;//add @
+ }//endif
+ }//endfor
+
+ //log("v_os :",v_os)
+
+ v_frame:=dec_STOMP(oct2char(v_os));
+
+ return v_frame;
+}
+
+
+type charstring MyCharstringType ( pattern "(([\q{0,0,0,14}-9]|[;-}])#(1,))" );
+
+
+type record Header {
+ MyCharstringType header_name,
+ MyCharstringType header_value
+}with {
+ variant "SEPARATOR(':',,)"
+ variant "END('\r\n','(\r)#(0,1)\n',)" //EOL
+}
+
+
+type record of Header Headers with {
+ variant "END('\r\n','(\r)#(0,1)\n',)" //EOL
+}
+
+type record STOMPFrame {
+
+ Command command,
+ Headers headers,
+ charstring payload optional
+
+}with {
+ variant "END('@@','[\q{0,0,0,64}]#(2,2)',)"
+}
+
+type enumerated Command {
+ SEND,
+ SUBSCRIBE,
+ UNSUBSCRIBE,
+ BEGIN,
+ COMMIT,
+ ABORT,
+ ACK,
+ NACK,
+ DISCONNECT,
+ CONNECTED,
+ CONNECT,
+ STOMP,
+ MESSAGE,
+ RECEIPT,
+ ERROR
+}
+with {
+ variant "END('\r\n','(\r)#(0,1)\n',)" //EOL
+
+}
+
+}with { encode "TEXT" }
+
+
diff --git a/src/STOMP_common.ttcn b/src/STOMP_common.ttcn
new file mode 100644
index 0000000..5c88bc0
--- /dev/null
+++ b/src/STOMP_common.ttcn
@@ -0,0 +1,29 @@
+///////////////////////////////////////////////////////////////////////////////
+//
+// Copyright (c) 2000-2017 Ericsson Telecom AB
+//
+// All rights reserved. This program and the accompanying materials
+// are made available under the terms of the Eclipse Public License v1.0
+// which accompanies this distribution, and is available at
+// http://www.eclipse.org/legal/epl-v10.html
+///////////////////////////////////////////////////////////////////////////////
+//
+// Contributors:
+// Elemer Lelik-initial implementation
+//
+//
+//This function permits extracting JSON messages from a TCP stream by calculating the message length
+//
+
+module STOMP_common
+{
+
+//-----------------------------------------------------------------------------
+//External functions
+//-----------------------------------------------------------------------------
+
+external function f_calc_STOMP_length( in octetstring data) return integer;
+
+}
+
+
diff --git a/src/STOMP_slicer.cc b/src/STOMP_slicer.cc
new file mode 100644
index 0000000..8b81427
--- /dev/null
+++ b/src/STOMP_slicer.cc
@@ -0,0 +1,55 @@
+///////////////////////////////////////////////////////////////////////////////
+//
+// Copyright (c) 2000-2017 Ericsson Telecom AB
+//
+// All rights reserved. This program and the accompanying materials
+// are made available under the terms of the Eclipse Public License v1.0
+// which accompanies this distribution, and is available at
+// http://www.eclipse.org/legal/epl-v10.html
+///////////////////////////////////////////////////////////////////////////////
+//
+// Contributors:
+// Elemer Lelik-initial implementation
+//
+//
+//This function permits extracting JSON messages from a TCP stream by calculating the message length
+//
+
+#include "STOMP_common.hh"
+#include <ctype.h>
+#include <string.h>
+#include <iostream>
+
+namespace STOMP__common {
+//returns length of first STOMP string in the input stream, calculated from index 0, or -1 in case of unsuccessful match
+INTEGER f__calc__STOMP__length(const OCTETSTRING& data){
+ int data_length=data.lengthof();
+ const unsigned char* ptr=(const unsigned char*)data;
+
+
+ for(int i=0; i<data_length; i++){
+
+ if (ptr[i] == '\0')
+ {
+ if( (ptr[i+1] != '\n') && (ptr[i+1] != '\r') ) return i+1;
+ else {
+
+
+ for(int j=i+1; j<data_length; j++){
+
+ if ( (ptr[j+1] != '\n') && (ptr[j+1] != '\r') ) return j+1;
+
+ }//endfor
+
+
+ }//endelse
+
+ }//endif
+
+ }//endfor
+
+ return -1;
+}//endfunction
+
+}//end ns
+
diff --git a/test/Makefile b/test/Makefile
new file mode 100644
index 0000000..3ed4e7d
--- /dev/null
+++ b/test/Makefile
@@ -0,0 +1,187 @@
+# This Makefile was generated by the Makefile Generator
+# of the TTCN-3 Test Executor version CRL 113 200/6 R2A
+# for Elemer Lelik (ethlel@esekilxxen1844) on Tue Jun 27 13:27:38 2017
+
+# Copyright (c) 2000-2017 Ericsson Telecom AB
+
+# The following make commands are available:
+# - make, make all Builds the executable test suite.
+# - make archive Archives all source files.
+# - make check Checks the semantics of TTCN-3 and ASN.1modules.
+# - make port Generates port skeletons.
+# - make clean Removes all generated files.
+# - make compile Translates TTCN-3 and ASN.1 modules to C++.
+# - make dep Creates/updates dependency list.
+# - make executable Builds the executable test suite.
+# - make library Builds the library archive.
+# - make objects Builds the object files without linking the executable.
+#
+# Set these variables...
+#
+
+# The path of your TTCN-3 Test Executor installation:
+# Uncomment this line to override the environment variable.
+# TTCN3_DIR =
+
+# Your platform: (SOLARIS, SOLARIS8, LINUX, FREEBSD or WIN32)
+PLATFORM = LINUX
+
+# Your C++ compiler:
+# (if you change the platform, you may need to change the compiler)
+CXX = g++
+
+# Flags for the C++ preprocessor (and makedepend as well):
+CPPFLAGS = -D$(PLATFORM) -I$(TTCN3_DIR)/include
+
+# Flags for the C++ compiler:
+CXXFLAGS = -Wall
+
+# Flags for the linker:
+LDFLAGS =
+
+ifeq ($(PLATFORM), WIN32)
+# Silence linker warnings.
+LDFLAGS += -Wl,--enable-auto-import,--enable-runtime-pseudo-reloc
+endif
+
+# Utility to create library files
+AR = ar
+ARFLAGS =
+
+# Flags for the TTCN-3 and ASN.1 compiler:
+COMPILER_FLAGS = -L
+
+# Execution mode: (either ttcn3 or ttcn3-parallel)
+TTCN3_LIB = ttcn3-parallel
+
+# The path of your OpenSSL installation:
+# If you do not have your own one, leave it unchanged.
+OPENSSL_DIR = $(TTCN3_DIR)
+
+# The path of your libxml2 installation:
+# If you do not have your own one, leave it unchanged.
+XMLDIR = $(TTCN3_DIR)
+
+# Directory to store the archived source files:
+# Note: you can set any directory except ./archive
+ARCHIVE_DIR = backup
+
+#
+# You may change these variables. Add your files if necessary...
+#
+
+# TTCN-3 modules of this project:
+TTCN3_MODULES = STOMP_Types.ttcn STOMP_test.ttcn
+
+# ASN.1 modules of this project:
+ASN1_MODULES =
+
+# C++ source & header files generated from the TTCN-3 & ASN.1 modules of
+# this project:
+GENERATED_SOURCES = STOMP_Types.cc STOMP_test.cc
+GENERATED_HEADERS = STOMP_Types.hh STOMP_test.hh
+
+# C/C++ Source & header files of Test Ports, external functions and
+# other modules:
+USER_SOURCES =
+USER_HEADERS =
+
+# Object files of this project that are needed for the executable test suite:
+OBJECTS = $(GENERATED_OBJECTS) $(USER_OBJECTS)
+
+GENERATED_OBJECTS = STOMP_Types.o STOMP_test.o
+
+USER_OBJECTS =
+
+# Other files of the project (Makefile, configuration files, etc.)
+# that will be added to the archived source files:
+OTHER_FILES = Makefile
+
+# The name of the executable test suite:
+EXECUTABLE = STOMP_Types
+
+
+
+LIBRARY = lib$(EXECUTABLE).a
+
+TARGET = $(EXECUTABLE)
+
+#
+# Do not modify these unless you know what you are doing...
+# Platform specific additional libraries:
+#
+SOLARIS_LIBS = -lsocket -lnsl -lxml2 -lresolv
+SOLARIS8_LIBS = -lsocket -lnsl -lxml2 -lresolv
+LINUX_LIBS = -lxml2 -lpthread -lrt
+FREEBSD_LIBS = -lxml2
+WIN32_LIBS = -lxml2
+
+#
+# Rules for building the executable...
+#
+
+all: $(TARGET) ;
+
+executable: $(EXECUTABLE) ;
+
+library: $(LIBRARY) ;
+
+objects: $(OBJECTS) compile;
+
+$(EXECUTABLE): $(OBJECTS)
+ if $(CXX) $(LDFLAGS) -o $@ $(OBJECTS) \
+ -L$(TTCN3_DIR)/lib -l$(TTCN3_LIB) \
+ -L$(OPENSSL_DIR)/lib -lcrypto \
+ -L$(XMLDIR)/lib $($(PLATFORM)_LIBS); \
+ then : ; else $(TTCN3_DIR)/bin/titanver $(OBJECTS); exit 1; fi
+
+$(LIBRARY): $(OBJECTS)
+ $(AR) -r $(ARFLAGS) $(LIBRARY) $(OBJECTS)
+
+.cc.o .c.o:
+ $(CXX) -c $(CPPFLAGS) $(CXXFLAGS) -o $@ $<
+
+$(GENERATED_SOURCES) $(GENERATED_HEADERS): compile
+ @if [ ! -f $@ ]; then rm -f compile; $(MAKE) compile; fi
+
+check: $(TTCN3_MODULES) $(ASN1_MODULES)
+ $(TTCN3_DIR)/bin/compiler -s $(COMPILER_FLAGS) \
+ $(TTCN3_MODULES) $(PREPROCESSED_TTCN3_MODULES) $(ASN1_MODULES)
+
+port: $(TTCN3_MODULES) $(ASN1_MODULES)
+ $(TTCN3_DIR)/bin/compiler -t $(COMPILER_FLAGS) \
+ $(TTCN3_MODULES) $(PREPROCESSED_TTCN3_MODULES) $(ASN1_MODULES)
+
+compile: $(TTCN3_MODULES) $(ASN1_MODULES)
+ $(TTCN3_DIR)/bin/compiler $(COMPILER_FLAGS) \
+ $(TTCN3_MODULES) $(ASN1_MODULES) - $?
+ touch $@
+
+clean:
+ -rm -f $(EXECUTABLE) $(LIBRARY) $(OBJECTS) $(GENERATED_HEADERS) \
+ $(GENERATED_SOURCES) compile \
+ tags *.log
+
+dep: $(GENERATED_SOURCES) $(USER_SOURCES) ;
+ makedepend $(CPPFLAGS) -DMAKEDEPEND_RUN $(GENERATED_SOURCES) $(USER_SOURCES)
+
+archive:
+ mkdir -p $(ARCHIVE_DIR)
+ tar -cvhf - $(TTCN3_MODULES) $(ASN1_MODULES) \
+ $(USER_HEADERS) $(USER_SOURCES) $(OTHER_FILES) \
+ | gzip >$(ARCHIVE_DIR)/`basename $(TARGET) .exe`-`date '+%y%m%d-%H%M'`.tgz
+
+diag:
+ $(TTCN3_DIR)/bin/compiler -v 2>&1
+ $(TTCN3_DIR)/bin/mctr_cli -v 2>&1
+ $(CXX) -v 2>&1
+ $(AR) -V 2>&1
+ @echo TTCN3_DIR=$(TTCN3_DIR)
+ @echo OPENSSL_DIR=$(OPENSSL_DIR)
+ @echo XMLDIR=$(XMLDIR)
+ @echo PLATFORM=$(PLATFORM)
+
+#
+# Add your rules here if necessary...
+#
+
diff --git a/test/STOMP_test.ttcn b/test/STOMP_test.ttcn
new file mode 100644
index 0000000..474973c
--- /dev/null
+++ b/test/STOMP_test.ttcn
@@ -0,0 +1,247 @@
+module STOMP_test
+{
+
+
+import from STOMP_Types all;
+
+
+
+
+//*******************************************************************************************
+//Templates
+
+
+template STOMPFrame t_message:=
+{
+
+ command:=MESSAGE,
+ headers:={ {header_name:="foo", header_value:="Hello"}, {header_name:="foo", header_value:="World"}},
+ payload:=omit
+
+
+}
+
+
+template STOMPFrame t_send:=
+{
+
+ command:=SEND,
+ headers:={ {header_name:="destination", header_value:="/queue/a"}, {header_name:="receipt", header_value:="message-12345"}},
+ payload:="hello queue a"
+
+
+}
+
+
+template STOMPFrame t_connect:=
+{
+
+ command:=CONNECT,
+ headers:={ {header_name:="accept-version", header_value:="1.2"}, {header_name:="host", header_value:="stomp.github.org"}},
+ payload:=omit
+
+
+}
+
+
+template STOMPFrame t_connected:=
+{
+
+ command:=CONNECTED,
+ headers:={ {header_name:="version", header_value:="1.2"}},
+ payload:=omit
+
+
+}
+
+
+template STOMPFrame t_error:=
+{
+
+ command:=ERROR,
+ headers:={ {header_name:="version", header_value:="1.2,2.1"},{header_name:="content-type", header_value:="text/plain"} },
+ payload:="Supported protocol versions are 1.2 2.1"
+
+
+}
+
+
+template STOMPFrame t_subscribe:=
+{
+
+ command:=SUBSCRIBE,
+ headers:={ {header_name:="id", header_value:="0"},{header_name:="destination", header_value:="/queue/foo"},{header_name:="ack", header_value:="client"} },
+ payload:=omit
+
+
+}
+
+
+template STOMPFrame t_unsubscribe:=
+{
+
+ command:=UNSUBSCRIBE,
+ headers:={ {header_name:="id", header_value:="0"} },
+ payload:=omit
+
+
+}
+
+
+template STOMPFrame t_begin:=
+{
+
+ command:=BEGIN,
+ headers:={ {header_name:="transaction", header_value:="tx1"} },
+ payload:=omit
+
+
+}
+
+template STOMPFrame t_ack:=
+{
+
+ command:=ACK,
+ headers:={{header_name:="id", header_value:="0"}, {header_name:="transaction", header_value:="tx1"} },
+ payload:=omit
+
+
+}
+
+
+template STOMPFrame t_nack:=
+{
+
+ command:=NACK,
+ headers:={{header_name:="id", header_value:="0"}, {header_name:="transaction", header_value:="tx1"} },
+ payload:=omit
+
+
+}
+
+template STOMPFrame t_commit:=
+{
+
+ command:=COMMIT,
+ headers:={ {header_name:="transaction", header_value:="tx1"} },
+ payload:=omit
+
+
+}
+
+
+template STOMPFrame t_abort:=
+{
+
+ command:=ABORT,
+ headers:={ {header_name:="transaction", header_value:="tx1"} },
+ payload:=omit
+
+
+}
+
+template STOMPFrame t_disconnect:=
+{
+
+ command:=DISCONNECT,
+ headers:={ {header_name:="receipt", header_value:="77"} },
+ payload:=omit
+
+
+}
+
+
+template STOMPFrame t_receipt:=
+{
+
+ command:=RECEIPT,
+ headers:={ {header_name:="receipt-id", header_value:="77"} },
+ payload:=omit
+
+
+}
+
+
+template STOMPFrame t_message1:=
+{
+
+ command:=MESSAGE,
+ headers:={ {header_name:="subscription", header_value:="0"}, {header_name:="message-id", header_value:="007"},{header_name:="destination", header_value:="/queue/a"}, {header_name:="content-type", header_value:="text/plain"}},
+ payload:="hello queue a"
+
+
+}
+
+
+
+template STOMPFrame t_error1:=
+{
+
+ command:=ERROR,
+ headers:={ {header_name:="receipt-id", header_value:="message@12345"},{header_name:="content-type", header_value:="text/plain"}, {header_name:="content-length", header_value:="171"},{header_name:="message", header_value:="malformed frame received"} },
+ payload:="The message:
+ -----
+ MESSAGE
+ destined:/queue/a
+ receipt:message@12345
+
+ Hello queue a!
+ -----
+ Did not contain a destination header, which is REQUIRED
+ for message propagation."
+
+
+}
+
+
+
+
+control {
+
+ var charstring v_char
+
+ log(f_dec_stomp(f_enc_stomp(valueof(t_message))))
+
+ log(f_dec_stomp(f_enc_stomp(valueof(t_send))))
+
+ log(f_dec_stomp(f_enc_stomp(valueof(t_connect))))
+
+ log(f_dec_stomp(f_enc_stomp(valueof(t_connected))))
+
+
+ log(f_dec_stomp(f_enc_stomp(valueof(t_error))))
+
+ log(f_dec_stomp(f_enc_stomp(valueof(t_subscribe))))
+
+
+ log(f_dec_stomp(f_enc_stomp(valueof(t_unsubscribe))))
+
+ log(f_dec_stomp(f_enc_stomp(valueof(t_begin))))
+
+ log(f_dec_stomp(f_enc_stomp(valueof(t_ack))))
+ log(f_dec_stomp(f_enc_stomp(valueof(t_nack))))
+
+
+ log(f_dec_stomp(f_enc_stomp(valueof(t_commit))))
+ log(f_dec_stomp(f_enc_stomp(valueof(t_abort))))
+
+
+ log(f_dec_stomp(f_enc_stomp(valueof(t_disconnect))))
+ log(f_dec_stomp(f_enc_stomp(valueof(t_receipt))))
+ log(f_dec_stomp(f_enc_stomp(valueof(t_message1))))
+
+ log(f_dec_stomp(f_enc_stomp(valueof(t_error1))))
+
+ v_char:="MESSAGE\nsubscription:0\nmessage-id:007\r\ndestination:/queue/a\ncontent-type:text/plain\n\r\nhello queue a@@"
+
+ log(dec_STOMP(v_char))
+
+
+
+
+
+
+}
+
+
+}
diff --git a/test/stomp.cfg b/test/stomp.cfg
new file mode 100644
index 0000000..8a260c1
--- /dev/null
+++ b/test/stomp.cfg
@@ -0,0 +1,17 @@
+[LOGGING]
+//LogFile := "myUDP.log"
+FileMask := LOG_ALL | TTCN_MATCHING
+#| TTCN_DEBUG
+ConsoleMask := TTCN_ERROR | TTCN_WARNING | TTCN_TESTCASE |
+TTCN_STATISTICS | TTCN_PORTEVENT
+LogSourceInfo := Yes
+
+[EXECUTE]
+STOMP_test.control
+
+
+
+[MAIN_CONTROLLER]
+LocalAddress := 127.0.0.1
+TCPPort := 9034
+
