Commit 21500ba6 authored by Yann Garcia's avatar Yann Garcia
Browse files

Add discover/get IOT

parent c2c625bf

go-packages/meep-iot-mgr/iot-mgr.go

+1 −1
Original line number Diff line number Diff line
@@ -500,7 +500,7 @@ func (tm *IotMgr) createDeviceWithIotPlatformId(device DeviceInfo, requestedIotP 
		// 	//DownlinkInfo *DownlinkInfo

		// 	ClientCertificate string

		// }

		sensor, err := registeredIotPlatformsMap[requestedIotPlatformId].oneM2M.OneM2M_create(sensor, requestedIotPlatformId, sensor.SensorType)

		sensor, err := registeredIotPlatformsMap[requestedIotPlatformId].oneM2M.OneM2M_create(sensor, "")

		if err != nil {

			return deviceResp, err

		}

go-packages/meep-sss-mgr/mqtt.go

+5 −4
Original line number Diff line number Diff line
@@ -177,14 +177,15 @@ func (broker_mqtt *SssMgrMqtt) send(p_ctx SssMgrBindingProtocolContext) (err err 
		body["pc"] = p_ctx.body

	}

	if p_ctx.queries != nil && len(p_ctx.queries) != 0 {

		d := make(map[string]int, 0)

		for k, v := range p_ctx.queries {

			if k == "ty" { // mosquitto_pub -d -q 0 -h 172.29.10.56 -p 1883 -t "/oneM2M/req/CAdmin/laboai-acme-ic-cse/json" -m "{\"fr\":\"CAdmin\",\"op\":2,\"rqi\":\"432bb877-7dc5-4e4d-b424-9c0d50604596\",\"rvi\":\"4\",\"to\":\"laboai-cse-in/YannouDomainAutomation/YannouGardenZone0\",\"ty\":3,\"fc\":{\"fu\":2,\"fo\":1}}"

				body[k], err = strconv.Atoi(v)

		d := make(map[string]interface{}, 0)

		for k, v := range p_ctx.queries { // FIXME FSCOM Check in pure string is working too?

			if k == "ty" {

				s, err := strconv.Atoi(v)

				if err != nil {

					log.Error(err.Error())

					return err, nil

				}

				d[k] = []int{s}

				continue

			}

			d[k], err = strconv.Atoi(v)

go-packages/meep-sss-mgr/onem2m-mgr.go

+140 −357

File changed.

Preview size limit exceeded, changes collapsed.

go-packages/meep-sss-mgr/onem2m-mgr_test.go

+965 −360

File changed.

Preview size limit exceeded, changes collapsed.