mirror of https://github.com/deavmi/doap
Compare commits
3 Commits
ff370f61d5
...
adec1d207b
Author | SHA1 | Date |
---|---|---|
Tristan B. Velloza Kildaire | adec1d207b | |
Tristan B. Velloza Kildaire | 9e93acd408 | |
Tristan B. Velloza Kildaire | 3bd731889d |
3
dub.json
3
dub.json
|
@ -3,6 +3,9 @@
|
|||
"Tristan B. Velloza Kildaire"
|
||||
],
|
||||
"copyright": "Copyright © 2023, Tristan B. Velloza Kildaire",
|
||||
"dependencies": {
|
||||
"niknaks": "~>0.1.0"
|
||||
},
|
||||
"description": "CoAP library for D",
|
||||
"license": "LGPL v3.0",
|
||||
"name": "doap",
|
||||
|
|
|
@ -3,7 +3,8 @@ module doap.client.client;
|
|||
import std.socket : Socket, Address, SocketType, ProtocolType, getAddress, parseAddress, InternetAddress, SocketShutdown;
|
||||
import doap.client.messaging;
|
||||
import doap.protocol;
|
||||
import doap.client.request : CoapRequestBuilder, CoapRequest, CoapRequestFuture;
|
||||
import doap.client.request : CoapRequestBuilder, CoapRequest, CoapRequestFuture, RequestState;
|
||||
import doap.client.exceptions : RequestTimeoutException;
|
||||
import core.sync.mutex : Mutex;
|
||||
import core.sync.condition : Condition;
|
||||
import std.container.slist : SList;
|
||||
|
@ -513,12 +514,12 @@ unittest
|
|||
client.close();
|
||||
}
|
||||
|
||||
// version(unittest)
|
||||
// {
|
||||
// import core.time : dur;
|
||||
// import doap.client.exceptions : RequestTimeoutException;
|
||||
// import doap.client.request : CoapRequestFuture, RequestState;
|
||||
// }
|
||||
version(unittest)
|
||||
{
|
||||
import core.time : dur;
|
||||
// import doap.client.exceptions : RequestTimeoutException;
|
||||
// import doap.client.request : CoapRequestFuture, RequestState;
|
||||
}
|
||||
|
||||
// /**
|
||||
// * Client testing
|
||||
|
|
|
@ -7,14 +7,8 @@ import core.sys.posix.sys.socket : MSG_TRUNC;
|
|||
import doap.protocol;
|
||||
import doap.exceptions;
|
||||
import doap.client.request : CoapRequest;
|
||||
|
||||
import std.stdio;
|
||||
|
||||
import std.socket : Socket, SocketSet;
|
||||
import std.socket : Address;
|
||||
|
||||
import std.socket : Socket, Address, SocketType, ProtocolType, getAddress, parseAddress, InternetAddress, SocketShutdown;
|
||||
|
||||
import std.socket : Socket, SocketSet, Address, SocketType, ProtocolType, getAddress, parseAddress, InternetAddress, SocketShutdown;
|
||||
import doap.client.messaging;
|
||||
|
||||
/**
|
||||
|
|
|
@ -3,294 +3,5 @@
|
|||
*/
|
||||
module doap.utils;
|
||||
|
||||
version(unittest)
|
||||
{
|
||||
import std.stdio : writeln;
|
||||
}
|
||||
|
||||
/**
|
||||
* Flips the given integral value
|
||||
*
|
||||
* Params:
|
||||
* bytesIn = the integral value
|
||||
* Returns: the flipped integral
|
||||
*/
|
||||
public T flip(T)(T bytesIn) if(__traits(isIntegral, T))
|
||||
{
|
||||
T copy = bytesIn;
|
||||
|
||||
ubyte* base = (cast(ubyte*)&bytesIn)+T.sizeof-1;
|
||||
ubyte* baseCopy = cast(ubyte*)©
|
||||
|
||||
for(ulong idx = 0; idx < T.sizeof; idx++)
|
||||
{
|
||||
*(baseCopy+idx) = *(base-idx);
|
||||
}
|
||||
|
||||
return copy;
|
||||
}
|
||||
|
||||
/**
|
||||
* Tests the `flip!(T)(T)` function
|
||||
*/
|
||||
unittest
|
||||
{
|
||||
version(BigEndian)
|
||||
{
|
||||
ushort i = 1;
|
||||
ushort flipped = flip(i);
|
||||
assert(flipped == 256);
|
||||
}
|
||||
else version(LittleEndian)
|
||||
{
|
||||
ushort i = 1;
|
||||
ushort flipped = flip(i);
|
||||
assert(flipped == 256);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Ordering
|
||||
*/
|
||||
public enum Order
|
||||
{
|
||||
/**
|
||||
* Little endian
|
||||
*/
|
||||
LE,
|
||||
|
||||
/**
|
||||
* Big endian
|
||||
*/
|
||||
BE
|
||||
}
|
||||
|
||||
/**
|
||||
* Swaps the bytes to the given ordering but does a no-op
|
||||
* if the ordering requested is the same as that of the
|
||||
* system's
|
||||
*
|
||||
* Params:
|
||||
* bytesIn = the integral value to swap
|
||||
* order = the byte ordering to request
|
||||
* Returns: the integral value
|
||||
*/
|
||||
public T order(T)(T bytesIn, Order order) if(__traits(isIntegral, T))
|
||||
{
|
||||
version(LittleEndian)
|
||||
{
|
||||
if(order == Order.LE)
|
||||
{
|
||||
return bytesIn;
|
||||
}
|
||||
else
|
||||
{
|
||||
return flip(bytesIn);
|
||||
}
|
||||
}
|
||||
else version(BigEndian)
|
||||
{
|
||||
if(order == Order.BE)
|
||||
{
|
||||
return bytesIn;
|
||||
}
|
||||
else
|
||||
{
|
||||
return flip(bytesIn);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Tests the `order!(T)(T, Order)`
|
||||
*
|
||||
* To Big Endian testing
|
||||
*/
|
||||
unittest
|
||||
{
|
||||
version(LittleEndian)
|
||||
{
|
||||
ushort i = 1;
|
||||
writeln("Pre-order: ", i);
|
||||
ushort ordered = order(i, Order.BE);
|
||||
writeln("Post-order: ", ordered);
|
||||
assert(ordered == 256);
|
||||
}
|
||||
else version(BigEndian)
|
||||
{
|
||||
ushort i = 1;
|
||||
writeln("Pre-order: ", i);
|
||||
ushort ordered = order(i, Order.BE);
|
||||
writeln("Post-order: ", ordered);
|
||||
assert(ordered == i);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Tests the `order!(T)(T, Order)`
|
||||
*
|
||||
* To Little Endian testing
|
||||
*/
|
||||
unittest
|
||||
{
|
||||
version(LittleEndian)
|
||||
{
|
||||
ushort i = 1;
|
||||
writeln("Pre-order: ", i);
|
||||
ushort ordered = order(i, Order.LE);
|
||||
writeln("Post-order: ", ordered);
|
||||
assert(ordered == i);
|
||||
}
|
||||
else version(BigEndian)
|
||||
{
|
||||
ushort i = 1;
|
||||
writeln("Pre-order: ", i);
|
||||
ushort ordered = order(i, Order.LE);
|
||||
writeln("Post-order: ", ordered);
|
||||
assert(ordered == 256);
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Checks if the given value is present in
|
||||
* the given array
|
||||
*
|
||||
* Params:
|
||||
* array = the array to check against
|
||||
* value = the value to check prescence
|
||||
* for
|
||||
* Returns: `true` if present, `false`
|
||||
* otherwise
|
||||
*/
|
||||
public bool isPresent(T)(T[] array, T value)
|
||||
{
|
||||
if(array.length == 0)
|
||||
{
|
||||
return false;
|
||||
}
|
||||
else
|
||||
{
|
||||
foreach(T cur; array)
|
||||
{
|
||||
if(cur == value)
|
||||
{
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Tests the `isPresent!(T)(T[], T)` function
|
||||
*/
|
||||
unittest
|
||||
{
|
||||
ubyte[] values = [1,2,3];
|
||||
foreach(ubyte value; values)
|
||||
{
|
||||
assert(isPresent(values, value));
|
||||
}
|
||||
assert(isPresent(values, 0) == false);
|
||||
assert(isPresent(values, 5) == false);
|
||||
}
|
||||
|
||||
/**
|
||||
* Given an array of values this tries to find
|
||||
* the next free value of which is NOT present
|
||||
* within the given array
|
||||
*
|
||||
* Params:
|
||||
* used = the array of values
|
||||
* Returns: the free value
|
||||
*/
|
||||
public T findNextFree(T)(T[] used) if(__traits(isIntegral, T))
|
||||
{
|
||||
T found;
|
||||
if(used.length == 0)
|
||||
{
|
||||
return 0;
|
||||
}
|
||||
else
|
||||
{
|
||||
found = 0;
|
||||
while(isPresent(used, found)) // FIXME: Constant loop if none available
|
||||
{
|
||||
found++;
|
||||
}
|
||||
|
||||
return found;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Tests the `findNextFree!(T)(T[])` function
|
||||
*/
|
||||
unittest
|
||||
{
|
||||
ubyte[] values = [1,2,3];
|
||||
ubyte free = findNextFree(values);
|
||||
assert(isPresent(values, free) == false);
|
||||
}
|
||||
|
||||
/**
|
||||
* Converts the given integral value to
|
||||
* its byte encoding
|
||||
*
|
||||
* Params:
|
||||
* integral = the integral value
|
||||
* Returns: a `ubyte[]` of the value
|
||||
*/
|
||||
public ubyte[] toBytes(T)(T integral) if(__traits(isIntegral, T))
|
||||
{
|
||||
ubyte[] bytes;
|
||||
|
||||
static if(integral.sizeof == 1)
|
||||
{
|
||||
bytes = [cast(ubyte)integral];
|
||||
}
|
||||
else static if(integral.sizeof == 2)
|
||||
{
|
||||
ubyte* ptrBase = cast(ubyte*)&integral;
|
||||
bytes = [*ptrBase, *(ptrBase+1)];
|
||||
}
|
||||
else static if(integral.sizeof == 4)
|
||||
{
|
||||
ubyte* ptrBase = cast(ubyte*)&integral;
|
||||
bytes = [*ptrBase, *(ptrBase+1), *(ptrBase+2), *(ptrBase+3)];
|
||||
}
|
||||
else static if(integral.sizeof == 8)
|
||||
{
|
||||
ubyte* ptrBase = cast(ubyte*)&integral;
|
||||
bytes = [*ptrBase, *(ptrBase+1), *(ptrBase+2), *(ptrBase+3), *(ptrBase+4), *(ptrBase+5), *(ptrBase+6), *(ptrBase+7)];
|
||||
}
|
||||
else
|
||||
{
|
||||
pragma(msg, "toBytes cannot support integral types greater than 8 bytes");
|
||||
static assert(false);
|
||||
}
|
||||
|
||||
return bytes;
|
||||
}
|
||||
|
||||
/**
|
||||
* Tests the `toBytes!(T)(T)` function
|
||||
*/
|
||||
unittest
|
||||
{
|
||||
version(LittleEndian)
|
||||
{
|
||||
ulong value = 1;
|
||||
ubyte[] bytes = toBytes(value);
|
||||
|
||||
assert(bytes == [1, 0, 0, 0, 0, 0, 0, 0]);
|
||||
}
|
||||
else version(BigEndian)
|
||||
{
|
||||
ulong value = 1;
|
||||
ubyte[] bytes = toBytes(value);
|
||||
|
||||
assert(bytes == [0, 0, 0, 0, 0, 0, 0, 1]);
|
||||
}
|
||||
}
|
||||
public import niknaks.bits : Order, order;
|
||||
public import niknaks.arrays : findNextFree;
|
Loading…
Reference in New Issue