18 Commits
Author SHA1 Message Date
Thorsten Sommer b443a7304a Adjusted the ICCC driver specification 2015-07-16 13:12:26 +02:00
Thorsten Sommer 597c2850f2 Fixed ICCC driver specification 2015-07-16 10:05:58 +02:00
Thorsten Sommer 63c31be87b Changed the ICCC driver specification 2015-07-16 08:44:54 +02:00
Thorsten Sommer 64cb1b8728 Extend the ICCC driver specification 2015-07-15 21:13:19 +02:00
Thorsten Sommer d071609988 Bugfix: The start-up message's values are wrong 2015-07-15 19:25:45 +02:00
Thorsten Sommer c1748edd8d Bugfix for the LogImpact class 2015-07-15 14:31:45 +02:00
Thorsten Sommer 041cda8a35 Extended the ICCC driver specification 2015-07-14 18:06:51 +02:00
Thorsten Sommer 6c6e52536a Preparation for the next release 2015-07-14 17:02:56 +02:00
Thorsten Sommer 630147ecdd Bugfix: Remove empty parameters 2015-07-14 17:02:42 +02:00
Thorsten Sommer 36bf26e12a Bugfix: The ICCC logging events are without project name 2015-07-14 16:34:25 +02:00
Thorsten Sommer 0bca5ebb7b Bugfix: The hash was wrong
* The checksum must be uppercase
* The data string was wrong
2015-07-14 16:33:50 +02:00
Thorsten Sommer 858cfc81e4 Fixed external ICCC component start-up 2015-07-14 16:32:48 +02:00
Thorsten Sommer 74b287017b Fixed the ICCCConnection class 2015-07-13 17:45:55 +02:00
Thorsten Sommer b74c9e7fa3 Fixed an issue for the ICCCConnection class 2015-07-13 16:33:39 +02:00
Thorsten Sommer a792a8e86f Fixed the ICCC driver specification 2015-07-13 11:38:09 +02:00
Thorsten Sommer 40fd2d5dfb Fixed the ICCC driver specification 2015-07-13 11:00:54 +02:00
Thorsten Sommer bfedc63eb6 Implemented the fixed ICCC driver specification 2015-07-13 10:57:56 +02:00
Thorsten Sommer 6ab4732b85 Fixed the ICCC driver specification 2015-07-13 10:57:30 +02:00
10 changed files with 23 additions and 6 deletions

No files matched your search

+1
View File
@@ -39,6 +39,7 @@ func ICCCListenerUpdateReceiver(data map[string][]string) (result map[string][]s
updatedObject.Command = messageData.Command
updatedObject.IPAddressPort = messageData.IPAddressPort
updatedObject.IsActive = messageData.IsActiveNew
updatedObject.Kind = messageData.Kind
// Update the entry:
if errUpdate := collectionListener.Update(selectionUpdate, updatedObject); errUpdate != nil {
+3 -2
View File
@@ -6,6 +6,7 @@ import (
"github.com/SommerEngineering/Ocean/Tools"
"net/url"
"sort"
"strings"
)
// Sign a message to secure it.
@@ -32,7 +33,7 @@ func signMessage(data map[string][]string) (result url.Values) {
// Now, loop over all the data:
for _, key := range keys {
// Get the value:
value := data[key]
value := data[key][0]
// Hash each key and value:
fmt.Fprintf(hash, "key=%s :: value=%s\n", key, value)
@@ -42,6 +43,6 @@ func signMessage(data map[string][]string) (result url.Values) {
result = url.Values(data)
// Append the sign:
result.Add(`checksum`, fmt.Sprintf("%x", hash.Sum(nil)))
result.Add(`checksum`, strings.ToUpper(fmt.Sprintf("%x", hash.Sum(nil))))
return
}
@@ -6,4 +6,5 @@ type ICCCListenerUpdate struct {
Command string
IPAddressPort string
IsActiveNew bool
Kind byte
}
+7
View File
@@ -0,0 +1,7 @@
package Log
// This function provides the project name for e.g. logging events
// coming trough the ICCC.
func GetProjectName() string {
return projectName
}
+7 -1
View File
@@ -121,10 +121,16 @@ func clearEntry(entry Meta.Entry) (result Meta.Entry) {
// Remove white spaces from the parameters.
func clearParameters(oldParameters []string) (result []string) {
for n := 0; n < len(oldParameters); n++ {
// Remove white spaces:
oldParameters[n] = removeWhitespaces(oldParameters[n])
// Is content left after removing?
if oldParameters[n] != `` {
// Yes, some content is still there. Thus, commit this entry:
result = append(result, oldParameters[n])
}
}
result = oldParameters
return
}
+1
View File
@@ -30,6 +30,7 @@ func ICCCNewLogEventReceiver(data map[string][]string) (result map[string][]stri
// Provide a log entry:
logEntry := LM.Entry{}
logEntry.Project = Log.GetProjectName()
logEntry.Sender = LM.Sender(messageData.Sender)
logEntry.Category = LM.ParseCategory(messageData.Category)
logEntry.Level = LM.ParseLevel(messageData.Level)
BIN
View File
Binary file not shown.
@@ -29,7 +29,7 @@ func icccComponentStartUpMessageReceiver(data map[string][]string) (result map[s
messageData := obj.(SystemMessages.ICCCComponentStartUpMessage)
// Provide a log entry:
Log.LogShort(senderName, LM.CategorySYSTEM, LM.LevelINFO, LM.MessageNameSTARTUP, `ICCC message: The external component is now up and ready.`, fmt.Sprintf("ipAddressPort=%s", messageData.IPAddressPort), fmt.Sprintf("name=", messageData.Name), fmt.Sprintf("version=", messageData.Version))
Log.LogShort(senderName, LM.CategorySYSTEM, LM.LevelINFO, LM.MessageNameSTARTUP, `ICCC message: The external component is now up and ready.`, fmt.Sprintf("ipAddressPort='%s'", messageData.IPAddressPort), fmt.Sprintf("name='%s'", messageData.Name), fmt.Sprintf("version='%s'", messageData.Version))
// An answer is necessary:
return ICCC.Message2Data("", "", SystemMessages.AnswerACK)
+1 -1
View File
@@ -29,7 +29,7 @@ func icccOceanStartUpMessageReceiver(data map[string][]string) (result map[strin
messageData := obj.(SystemMessages.ICCCOceanStartUpMessage)
// Provide a log entry:
Log.LogShort(senderName, LM.CategorySYSTEM, LM.LevelINFO, LM.MessageNameSTARTUP, `ICCC message: The Ocean server is now up and ready.`, fmt.Sprintf("public server=%s", messageData.PublicIPAddressPort), fmt.Sprintf("admin server=%s", messageData.AdminIPAddressPort), fmt.Sprintf("Ocean's version=%s", messageData.OceanVersion))
Log.LogShort(senderName, LM.CategorySYSTEM, LM.LevelINFO, LM.MessageNameSTARTUP, `ICCC message: The Ocean server is now up and ready.`, fmt.Sprintf("public server='%s'", messageData.PublicIPAddressPort), fmt.Sprintf("admin server='%s'", messageData.AdminIPAddressPort), fmt.Sprintf("Ocean's version='%s'", messageData.OceanVersion))
// An answer is necessary:
return ICCC.Message2Data("", "", SystemMessages.AnswerACK)
+1 -1
View File
@@ -1,5 +1,5 @@
package Version
var (
oceansVersion string = `2.0.2` // Ocean's current version
oceansVersion string = `2.0.5` // Ocean's current version
)