Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
jio_mebibou
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
Alexandra Rogova
jio_mebibou
Commits
d57087fe
Commit
d57087fe
authored
Apr 08, 2019
by
Guillaume Royer
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
chore: release files
parent
61dcb661
Changes
3
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
1399 additions
and
51 deletions
+1399
-51
Makefile
Makefile
+3
-1
dist/jio-latest-node.js
dist/jio-latest-node.js
+713
-27
dist/jio-latest.js
dist/jio-latest.js
+683
-23
No files found.
Makefile
View file @
d57087fe
...
@@ -151,7 +151,8 @@ ${JIOVERSION}: ${EXTERNALDIR}/URI.js \
...
@@ -151,7 +151,8 @@ ${JIOVERSION}: ${EXTERNALDIR}/URI.js \
${SRCDIR}/jio.storage/indexeddbstorage.js
\
${SRCDIR}/jio.storage/indexeddbstorage.js
\
${SRCDIR}/jio.storage/cryptstorage.js
\
${SRCDIR}/jio.storage/cryptstorage.js
\
${SRCDIR}/jio.storage/fbstorage.js
\
${SRCDIR}/jio.storage/fbstorage.js
\
${SRCDIR}/jio.storage/cloudooostorage.js
${SRCDIR}/jio.storage/cloudooostorage.js
\
${SRCDIR}/jio.storage/mappingstorage.js
@
mkdir
-p
$
(
@D
)
@
mkdir
-p
$
(
@D
)
cat
$^
>
$@
cat
$^
>
$@
...
@@ -190,6 +191,7 @@ ${JIONODEVERSION}: ${SRCDIR}/node/jio-start.js \
...
@@ -190,6 +191,7 @@ ${JIONODEVERSION}: ${SRCDIR}/node/jio-start.js \
${SRCDIR}/jio.storage/drivetojiomapping.js
\
${SRCDIR}/jio.storage/drivetojiomapping.js
\
${SRCDIR}/jio.storage/documentstorage.js
\
${SRCDIR}/jio.storage/documentstorage.js
\
${SRCDIR}/jio.storage/fbstorage.js
\
${SRCDIR}/jio.storage/fbstorage.js
\
${SRCDIR}/jio.storage/mappingstorage.js
\
${SRCDIR}/node/jio-end.js
${SRCDIR}/node/jio-end.js
@
mkdir
-p
$
(
@D
)
@
mkdir
-p
$
(
@D
)
cat
$^
>
$@
cat
$^
>
$@
...
...
dist/jio-latest-node.js
View file @
d57087fe
...
@@ -8052,7 +8052,6 @@ parse: function parse(input) {
...
@@ -8052,7 +8052,6 @@ parse: function parse(input) {
vstack
.
length
=
vstack
.
length
-
n
;
vstack
.
length
=
vstack
.
length
-
n
;
lstack
.
length
=
lstack
.
length
-
n
;
lstack
.
length
=
lstack
.
length
-
n
;
}
}
_token_stack
:
var
lex
=
function
()
{
var
lex
=
function
()
{
var
token
;
var
token
;
token
=
lexer
.
lex
()
||
EOF
;
token
=
lexer
.
lex
()
||
EOF
;
...
@@ -9849,11 +9848,10 @@ return new Parser;
...
@@ -9849,11 +9848,10 @@ return new Parser;
try
{
try
{
return
window
.
atob
(
str
);
return
window
.
atob
(
str
);
}
catch
(
err
)
{
}
catch
(
err
)
{
var
buffer
;
var
buffer
=
Buffer
.
from
(
str
.
toString
(),
'
base64
'
);
if
(
str
instanceof
Buffer
)
{
// Provide the same behaviour than the browser atob
buffer
=
str
;
if
(
buffer
.
toString
(
'
base64
'
)
!==
str
)
{
}
else
{
throw
new
Error
(
'
The string to be decoded is not correctly encoded.
'
);
buffer
=
Buffer
.
from
(
str
.
toString
(),
'
base64
'
);
}
}
return
buffer
.
toString
(
'
binary
'
);
return
buffer
.
toString
(
'
binary
'
);
}
}
...
@@ -9865,13 +9863,7 @@ return new Parser;
...
@@ -9865,13 +9863,7 @@ return new Parser;
try
{
try
{
return
window
.
btoa
(
str
);
return
window
.
btoa
(
str
);
}
catch
(
err
)
{
}
catch
(
err
)
{
var
buffer
;
return
Buffer
.
from
(
str
.
toString
(),
'
binary
'
).
toString
(
'
base64
'
);
if
(
str
instanceof
Buffer
)
{
buffer
=
str
;
}
else
{
buffer
=
Buffer
.
from
(
str
.
toString
(),
'
binary
'
);
}
return
buffer
.
toString
(
'
base64
'
);
}
}
}
}
...
@@ -9879,8 +9871,8 @@ return new Parser;
...
@@ -9879,8 +9871,8 @@ return new Parser;
}(
window
,
WeakMap
,
ArrayBuffer
,
Uint8Array
));
}(
window
,
WeakMap
,
ArrayBuffer
,
Uint8Array
));
var
XMLHttpRequest
=
global
.
XMLHttpRequest
||
module
.
exports
,
global
.
XMLHttpRequest
=
module
.
exports
;
Blob
=
window
.
Blob
,
var
Blob
=
window
.
Blob
,
atob
=
window
.
atob
,
atob
=
window
.
atob
,
btoa
=
window
.
btoa
,
btoa
=
window
.
btoa
,
FileReader
=
window
.
FileReader
,
FileReader
=
window
.
FileReader
,
...
@@ -10674,7 +10666,7 @@ var XMLHttpRequest = global.XMLHttpRequest || module.exports,
...
@@ -10674,7 +10666,7 @@ var XMLHttpRequest = global.XMLHttpRequest || module.exports,
*/
*/
/*global window */
/*global window */
(
function
(
window
,
jIO
,
Blob
)
{
(
function
(
window
,
jIO
,
Blob
,
RSVP
)
{
"
use strict
"
;
"
use strict
"
;
var
FormData
,
var
FormData
,
...
@@ -10696,32 +10688,71 @@ var XMLHttpRequest = global.XMLHttpRequest || module.exports,
...
@@ -10696,32 +10688,71 @@ var XMLHttpRequest = global.XMLHttpRequest || module.exports,
};
};
window
.
FormData
=
FormData
;
window
.
FormData
=
FormData
;
function
convertToBlob
(
promise
,
convert
)
{
if
(
!
convert
)
{
return
promise
;
}
var
result
;
if
(
promise
instanceof
RSVP
.
Queue
)
{
result
=
promise
;
}
else
{
result
=
new
RSVP
.
Queue
()
.
push
(
function
()
{
return
promise
;
});
}
return
result
.
push
(
function
(
evt
)
{
evt
.
target
.
response
=
new
Blob
(
[
evt
.
target
.
response
||
evt
.
target
.
responseText
],
{
type
:
evt
.
target
.
getResponseHeader
(
'
Content-Type
'
)}
);
return
evt
;
});
}
originalAjax
=
jIO
.
util
.
ajax
;
originalAjax
=
jIO
.
util
.
ajax
;
jIO
.
util
.
ajax
=
function
ajax
(
param
)
{
jIO
.
util
.
ajax
=
function
ajax
(
param
)
{
var
result
,
need_convertion
=
(
param
.
dataType
===
'
blob
'
);
// Copy the param dict document (no need for deep copy) to
// allow tests to check them
param
=
Object
.
assign
({},
param
);
if
(
need_convertion
)
{
param
.
dataType
=
'
arraybuffer
'
;
}
if
(
param
.
data
instanceof
Blob
)
{
if
(
param
.
data
instanceof
Blob
)
{
// Blob is not supported by xhr2, so convert to ArrayBuffer instead
// Blob is not supported by xhr2, so convert to ArrayBuffer instead
return
jIO
.
util
.
readBlobAsArrayBuffer
(
param
.
data
).
then
(
function
(
data
)
{
result
=
new
RSVP
.
Queue
()
param
.
data
=
data
.
target
.
result
;
.
push
(
function
()
{
return
jIO
.
util
.
readBlobAsArrayBuffer
(
param
.
data
);
})
.
push
(
function
(
evt
)
{
param
.
data
=
evt
.
target
.
result
;
return
originalAjax
(
param
);
return
originalAjax
(
param
);
});
});
}
}
else
if
(
param
.
data
instanceof
FormData
)
{
if
(
param
.
data
instanceof
FormData
)
{
// Implement minimal FormData for erp5storage
// Implement minimal FormData for erp5storage
if
(
!
param
.
hasOwnProperty
(
'
headers
'
))
{
if
(
!
param
.
hasOwnProperty
(
'
headers
'
))
{
param
.
headers
=
{};
param
.
headers
=
{};
}
else
{
// Copy the param dict document (no need for deep copy) to
// allow tests to check them
param
.
headers
=
Object
.
assign
({},
param
.
headers
);
}
}
param
.
headers
[
"
Content-Type
"
]
=
"
multipart
\
/form-data; boundary=
"
+
param
.
headers
[
"
Content-Type
"
]
=
"
multipart
\
/form-data; boundary=
"
+
param
.
data
.
boundary
;
param
.
data
.
boundary
;
param
.
data
.
body
+=
'
--
'
+
param
.
data
.
boundary
+
'
--
\r\n
'
;
param
.
data
.
body
+=
'
--
'
+
param
.
data
.
boundary
+
'
--
\r\n
'
;
param
.
data
=
param
.
data
.
body
;
param
.
data
=
param
.
data
.
body
;
return
originalAjax
(
param
);
result
=
originalAjax
(
param
);
}
else
{
result
=
originalAjax
(
param
);
}
}
return
originalAjax
(
param
);
return
convertToBlob
(
result
,
need_convertion
);
};
};
}(
window
,
window
.
jIO
,
window
.
Blob
));
}(
window
,
window
.
jIO
,
window
.
Blob
,
window
.
RSVP
));
// Define a global variable to allow storages to access jIO
// Define a global variable to allow storages to access jIO
var
jIO
=
window
.
jIO
,
var
jIO
=
window
.
jIO
,
...
@@ -15309,7 +15340,662 @@ var jIO = window.jIO,
...
@@ -15309,7 +15340,662 @@ var jIO = window.jIO,
jIO
.
addStorage
(
'
facebook
'
,
FBStorage
);
jIO
.
addStorage
(
'
facebook
'
,
FBStorage
);
}(
jIO
,
RSVP
,
UriTemplate
));
}(
jIO
,
RSVP
,
UriTemplate
));
/*jslint indent:2, maxlen: 80, nomen: true */
/*global jIO, RSVP, UriTemplate, SimpleQuery, ComplexQuery, QueryFactory,
Query, FormData*/
(
function
(
jIO
,
RSVP
,
UriTemplate
,
SimpleQuery
,
ComplexQuery
,
QueryFactory
,
Query
,
FormData
)
{
"
use strict
"
;
function
getSubIdEqualSubProperty
(
storage
,
value
,
key
)
{
var
query
;
if
(
storage
.
_no_sub_query_id
)
{
throw
new
jIO
.
util
.
jIOError
(
'
no sub query id active
'
,
404
);
}
if
(
!
value
)
{
throw
new
jIO
.
util
.
jIOError
(
'
can not find document with
'
+
key
+
'
: undefined
'
,
404
);
}
if
(
storage
.
_mapping_id_memory_dict
[
value
])
{
return
storage
.
_mapping_id_memory_dict
[
value
];
}
query
=
new
SimpleQuery
({
key
:
key
,
value
:
value
,
type
:
"
simple
"
});
if
(
storage
.
_query
.
query
!==
undefined
)
{
query
=
new
ComplexQuery
({
operator
:
"
AND
"
,
query_list
:
[
query
,
storage
.
_query
.
query
],
type
:
"
complex
"
});
}
query
=
Query
.
objectToSearchText
(
query
);
return
storage
.
_sub_storage
.
allDocs
({
"
query
"
:
query
,
"
sort_on
"
:
storage
.
_query
.
sort_on
,
"
select_list
"
:
storage
.
_query
.
select_list
,
"
limit
"
:
storage
.
_query
.
limit
})
.
push
(
function
(
data
)
{
if
(
data
.
data
.
total_rows
===
0
)
{
throw
new
jIO
.
util
.
jIOError
(
"
Can not find document with (
"
+
key
+
"
,
"
+
value
+
"
)
"
,
404
);
}
if
(
data
.
data
.
total_rows
>
1
)
{
throw
new
TypeError
(
"
id must be unique field:
"
+
key
+
"
, result:
"
+
data
.
data
.
rows
.
toString
());
}
storage
.
_mapping_id_memory_dict
[
value
]
=
data
.
data
.
rows
[
0
].
id
;
return
data
.
data
.
rows
[
0
].
id
;
});
}
/*jslint unparam: true*/
var
mapping_function
=
{
"
equalSubProperty
"
:
{
"
mapToSubProperty
"
:
function
(
property
,
sub_doc
,
doc
,
args
,
id
)
{
sub_doc
[
args
]
=
doc
[
property
];
return
args
;
},
"
mapToMainProperty
"
:
function
(
property
,
sub_doc
,
doc
,
args
,
sub_id
)
{
if
(
sub_doc
.
hasOwnProperty
(
args
))
{
doc
[
property
]
=
sub_doc
[
args
];
}
return
args
;
},
"
mapToSubId
"
:
function
(
storage
,
doc
,
id
,
args
)
{
if
(
doc
!==
undefined
)
{
if
(
storage
.
_property_for_sub_id
&&
doc
.
hasOwnProperty
(
storage
.
_property_for_sub_id
))
{
return
doc
[
storage
.
_property_for_sub_id
];
}
}
return
getSubIdEqualSubProperty
(
storage
,
id
,
storage
.
_map_id
[
1
]);
},
"
mapToId
"
:
function
(
storage
,
sub_doc
,
sub_id
,
args
)
{
return
sub_doc
[
args
];
}
},
"
equalValue
"
:
{
"
mapToSubProperty
"
:
function
(
property
,
sub_doc
,
doc
,
args
)
{
sub_doc
[
property
]
=
args
;
return
property
;
},
"
mapToMainProperty
"
:
function
(
property
)
{
return
property
;
}
},
"
ignore
"
:
{
"
mapToSubProperty
"
:
function
()
{
return
false
;
},
"
mapToMainProperty
"
:
function
(
property
)
{
return
property
;
}
},
"
equalSubId
"
:
{
"
mapToSubProperty
"
:
function
(
property
,
sub_doc
,
doc
)
{
sub_doc
[
property
]
=
doc
[
property
];
return
property
;
},
"
mapToMainProperty
"
:
function
(
property
,
sub_doc
,
doc
,
args
,
sub_id
)
{
if
(
sub_id
===
undefined
&&
sub_doc
.
hasOwnProperty
(
property
))
{
doc
[
property
]
=
sub_doc
[
property
];
}
else
{
doc
[
property
]
=
sub_id
;
}
return
property
;
},
"
mapToSubId
"
:
function
(
storage
,
doc
,
id
,
args
)
{
return
id
;
},
"
mapToId
"
:
function
(
storage
,
sub_doc
,
sub_id
)
{
return
sub_id
;
}
},
"
keep
"
:
{
"
mapToSubProperty
"
:
function
(
property
,
sub_doc
,
doc
)
{
sub_doc
[
property
]
=
doc
[
property
];
return
property
;
},
"
mapToMainProperty
"
:
function
(
property
,
sub_doc
,
doc
)
{
doc
[
property
]
=
sub_doc
[
property
];
return
property
;
}
},
"
switchPropertyValue
"
:
{
"
mapToSubProperty
"
:
function
(
property
,
sub_doc
,
doc
,
args
)
{
sub_doc
[
args
[
0
]]
=
args
[
1
][
doc
[
property
]];
return
args
[
0
];
},
"
mapToMainProperty
"
:
function
(
property
,
sub_doc
,
doc
,
args
)
{
var
subvalue
,
value
=
sub_doc
[
args
[
0
]];
for
(
subvalue
in
args
[
1
])
{
if
(
args
[
1
].
hasOwnProperty
(
subvalue
))
{
if
(
value
===
args
[
1
][
subvalue
])
{
doc
[
property
]
=
subvalue
;
return
property
;
}
}
}
}
}
};
/*jslint unparam: false*/
function
initializeQueryAndDefaultMapping
(
storage
)
{
var
property
,
query_list
=
[];
for
(
property
in
storage
.
_mapping_dict
)
{
if
(
storage
.
_mapping_dict
.
hasOwnProperty
(
property
))
{
if
(
storage
.
_mapping_dict
[
property
][
0
]
===
"
equalValue
"
)
{
if
(
storage
.
_mapping_dict
[
property
][
1
]
===
undefined
)
{
throw
new
jIO
.
util
.
jIOError
(
"
equalValue has not parameter
"
,
400
);
}
storage
.
_default_mapping
[
property
]
=
storage
.
_mapping_dict
[
property
][
1
];
query_list
.
push
(
new
SimpleQuery
({
key
:
property
,
value
:
storage
.
_mapping_dict
[
property
][
1
],
type
:
"
simple
"
}));
}
if
(
storage
.
_mapping_dict
[
property
][
0
]
===
"
equalSubId
"
)
{
if
(
storage
.
_property_for_sub_id
!==
undefined
)
{
throw
new
jIO
.
util
.
jIOError
(
"
equalSubId can be defined one time
"
,
400
);
}
storage
.
_property_for_sub_id
=
property
;
}
}
}
if
(
storage
.
_map_id
[
0
]
===
"
equalSubProperty
"
)
{
storage
.
_mapping_dict
[
storage
.
_map_id
[
1
]]
=
[
"
keep
"
];
}
if
(
storage
.
_query
.
query
!==
undefined
)
{
query_list
.
push
(
QueryFactory
.
create
(
storage
.
_query
.
query
));
}
if
(
query_list
.
length
>
1
)
{
storage
.
_query
.
query
=
new
ComplexQuery
({
type
:
"
complex
"
,
query_list
:
query_list
,
operator
:
"
AND
"
});
}
else
if
(
query_list
.
length
===
1
)
{
storage
.
_query
.
query
=
query_list
[
0
];
}
}
function
MappingStorage
(
spec
)
{
this
.
_mapping_dict
=
spec
.
property
||
{};
this
.
_sub_storage
=
jIO
.
createJIO
(
spec
.
sub_storage
);
this
.
_map_all_property
=
spec
.
map_all_property
!==
undefined
?
spec
.
map_all_property
:
true
;
this
.
_no_sub_query_id
=
spec
.
no_sub_query_id
;
this
.
_attachment_mapping_dict
=
spec
.
attachment
||
{};
this
.
_query
=
spec
.
query
||
{};
this
.
_map_id
=
spec
.
id
||
[
"
equalSubId
"
];
this
.
_id_mapped
=
(
spec
.
id
!==
undefined
)
?
spec
.
id
[
1
]
:
false
;
if
(
this
.
_query
.
query
!==
undefined
)
{
this
.
_query
.
query
=
QueryFactory
.
create
(
this
.
_query
.
query
);
}
this
.
_default_mapping
=
{};
this
.
_mapping_id_memory_dict
=
{};
this
.
_attachment_list
=
spec
.
attachment_list
||
[];
this
.
_caching_dict
=
{
id
:
{}};
initializeQueryAndDefaultMapping
(
this
);
}
function
getAttachmentId
(
storage
,
sub_id
,
attachment_id
,
method
)
{
var
mapping_dict
=
storage
.
_attachment_mapping_dict
;
if
(
mapping_dict
!==
undefined
&&
mapping_dict
[
attachment_id
]
!==
undefined
&&
mapping_dict
[
attachment_id
][
method
]
!==
undefined
&&
mapping_dict
[
attachment_id
][
method
].
uri_template
!==
undefined
)
{
return
UriTemplate
.
parse
(
mapping_dict
[
attachment_id
][
method
].
uri_template
).
expand
({
id
:
sub_id
});
}
return
attachment_id
;
}
function
getSubStorageId
(
storage
,
id
,
doc
)
{
if
(
storage
.
_caching_dict
.
id
.
hasOwnProperty
(
id
))
{
return
new
RSVP
.
Queue
()
.
push
(
function
()
{
return
storage
.
_caching_dict
.
id
[
id
];
});
}
return
new
RSVP
.
Queue
()
.
push
(
function
()
{
var
map_info
=
storage
.
_map_id
||
[
"
equalSubId
"
];
if
(
storage
.
_property_for_sub_id
&&
doc
!==
undefined
&&
doc
.
hasOwnProperty
(
storage
.
_property_for_sub_id
))
{
return
doc
[
storage
.
_property_for_sub_id
];
}
return
mapping_function
[
map_info
[
0
]].
mapToSubId
(
storage
,
doc
,
id
,
map_info
[
1
]
);
})
.
push
(
function
(
sub_id
)
{
storage
.
_caching_dict
.
id
[
id
]
=
sub_id
;
return
sub_id
;
});
}
function
mapToSubProperty
(
storage
,
property
,
sub_doc
,
doc
,
id
)
{
var
mapping_info
=
storage
.
_mapping_dict
[
property
]
||
[
"
keep
"
];
return
mapping_function
[
mapping_info
[
0
]].
mapToSubProperty
(
property
,
sub_doc
,
doc
,
mapping_info
[
1
],
id
);
}
function
mapToMainProperty
(
storage
,
property
,
sub_doc
,
doc
,
sub_id
)
{
var
mapping_info
=
storage
.
_mapping_dict
[
property
]
||
[
"
keep
"
];
return
mapping_function
[
mapping_info
[
0
]].
mapToMainProperty
(
property
,
sub_doc
,
doc
,
mapping_info
[
1
],
sub_id
);
}
function
mapToMainDocument
(
storage
,
sub_doc
,
sub_id
)
{
var
doc
=
{},
property
,
property_list
=
[
storage
.
_id_mapped
];
for
(
property
in
storage
.
_mapping_dict
)
{
if
(
storage
.
_mapping_dict
.
hasOwnProperty
(
property
))
{
property_list
.
push
(
mapToMainProperty
(
storage
,
property
,
sub_doc
,
doc
,
sub_id
));
}
}
if
(
storage
.
_map_all_property
)
{
for
(
property
in
sub_doc
)
{
if
(
sub_doc
.
hasOwnProperty
(
property
))
{
if
(
property_list
.
indexOf
(
property
)
<
0
)
{
doc
[
property
]
=
sub_doc
[
property
];
}
}
}
}
if
(
storage
.
_map_for_sub_storage_id
!==
undefined
)
{
doc
[
storage
.
_map_for_sub_storage_id
]
=
sub_id
;
}
return
doc
;
}
function
mapToSubstorageDocument
(
storage
,
doc
,
id
)
{
var
sub_doc
=
{},
property
;
for
(
property
in
doc
)
{
if
(
doc
.
hasOwnProperty
(
property
))
{
mapToSubProperty
(
storage
,
property
,
sub_doc
,
doc
,
id
);
}
}
for
(
property
in
storage
.
_default_mapping
)
{
if
(
storage
.
_default_mapping
.
hasOwnProperty
(
property
))
{
sub_doc
[
property
]
=
storage
.
_default_mapping
[
property
];
}
}
if
(
storage
.
_map_id
[
0
]
===
"
equalSubProperty
"
&&
id
!==
undefined
)
{
sub_doc
[
storage
.
_map_id
[
1
]]
=
id
;
}
return
sub_doc
;
}
function
handleAttachment
(
storage
,
argument_list
,
method
)
{
return
getSubStorageId
(
storage
,
argument_list
[
0
])
.
push
(
function
(
sub_id
)
{
argument_list
[
0
]
=
sub_id
;
var
old_id
=
argument_list
[
1
];
argument_list
[
1
]
=
getAttachmentId
(
storage
,
argument_list
[
0
],
argument_list
[
1
],
method
);
if
(
storage
.
_attachment_list
.
length
>
0
&&
storage
.
_attachment_list
.
indexOf
(
old_id
)
<
0
)
{
if
(
method
===
"
get
"
)
{
throw
new
jIO
.
util
.
jIOError
(
"
unhautorized attachment
"
,
404
);
}
return
;
}
return
storage
.
_sub_storage
[
method
+
"
Attachment
"
].
apply
(
storage
.
_sub_storage
,
argument_list
);
});
}
MappingStorage
.
prototype
.
get
=
function
(
id
)
{
var
storage
=
this
;
return
getSubStorageId
(
this
,
id
)
.
push
(
function
(
sub_id
)
{
return
storage
.
_sub_storage
.
get
(
sub_id
)
.
push
(
function
(
sub_doc
)
{
return
mapToMainDocument
(
storage
,
sub_doc
,
sub_id
);
});
});
};
MappingStorage
.
prototype
.
post
=
function
(
doc
)
{
var
sub_doc
=
mapToSubstorageDocument
(
this
,
doc
),
id
=
doc
[
this
.
_property_for_sub_id
],
storage
=
this
;
if
(
this
.
_property_for_sub_id
&&
id
!==
undefined
)
{
return
this
.
_sub_storage
.
put
(
id
,
sub_doc
);
}
if
(
this
.
_id_mapped
&&
doc
[
this
.
_id_mapped
]
!==
undefined
)
{
return
getSubStorageId
(
storage
,
id
,
doc
)
.
push
(
function
(
sub_id
)
{
return
storage
.
_sub_storage
.
put
(
sub_id
,
sub_doc
);
})
.
push
(
function
()
{
return
doc
[
storage
.
_id_mapped
];
})
.
push
(
undefined
,
function
(
error
)
{
if
(
error
instanceof
jIO
.
util
.
jIOError
)
{
return
storage
.
_sub_storage
.
post
(
sub_doc
);
}
throw
error
;
});
}
throw
new
jIO
.
util
.
jIOError
(
"
post is not supported with id mapped
"
,
400
);
};
MappingStorage
.
prototype
.
put
=
function
(
id
,
doc
)
{
var
storage
=
this
,
sub_doc
=
mapToSubstorageDocument
(
this
,
doc
,
id
);
return
getSubStorageId
(
this
,
id
,
doc
)
.
push
(
function
(
sub_id
)
{
return
storage
.
_sub_storage
.
put
(
sub_id
,
sub_doc
);
})
.
push
(
undefined
,
function
(
error
)
{
if
(
error
instanceof
jIO
.
util
.
jIOError
&&
error
.
status_code
===
404
)
{
return
storage
.
_sub_storage
.
post
(
sub_doc
);
}
throw
error
;
})
.
push
(
function
()
{
return
id
;
});
};
MappingStorage
.
prototype
.
remove
=
function
(
id
)
{
var
storage
=
this
;
return
getSubStorageId
(
this
,
id
)
.
push
(
function
(
sub_id
)
{
return
storage
.
_sub_storage
.
remove
(
sub_id
);
})
.
push
(
function
()
{
return
id
;
});
};
MappingStorage
.
prototype
.
getAttachment
=
function
()
{
return
handleAttachment
(
this
,
arguments
,
"
get
"
);
};
MappingStorage
.
prototype
.
putAttachment
=
function
(
id
,
attachment_id
,
blob
)
{
var
storage
=
this
,
mapping_dict
=
storage
.
_attachment_mapping_dict
;
// THIS IS REALLY BAD, FIND AN OTHER WAY IN FUTURE
if
(
mapping_dict
!==
undefined
&&
mapping_dict
[
attachment_id
]
!==
undefined
&&
mapping_dict
[
attachment_id
].
put
!==
undefined
&&
mapping_dict
[
attachment_id
].
put
.
erp5_put_template
!==
undefined
)
{
return
getSubStorageId
(
storage
,
id
)
.
push
(
function
(
sub_id
)
{
var
url
=
UriTemplate
.
parse
(
mapping_dict
[
attachment_id
].
put
.
erp5_put_template
).
expand
({
id
:
sub_id
}),
data
=
new
FormData
();
data
.
append
(
"
field_my_file
"
,
blob
);
data
.
append
(
"
form_id
"
,
"
File_view
"
);
return
jIO
.
util
.
ajax
({
"
type
"
:
"
POST
"
,
"
url
"
:
url
,
"
data
"
:
data
,
"
xhrFields
"
:
{
withCredentials
:
true
}
});
});
}
return
handleAttachment
(
this
,
arguments
,
"
put
"
,
id
)
.
push
(
function
()
{
return
attachment_id
;
});
};
MappingStorage
.
prototype
.
removeAttachment
=
function
(
id
,
attachment_id
)
{
return
handleAttachment
(
this
,
arguments
,
"
remove
"
,
id
)
.
push
(
function
()
{
return
attachment_id
;
});
};
MappingStorage
.
prototype
.
allAttachments
=
function
(
id
)
{
var
storage
=
this
,
sub_id
;
return
getSubStorageId
(
storage
,
id
)
.
push
(
function
(
sub_id_result
)
{
sub_id
=
sub_id_result
;
return
storage
.
_sub_storage
.
allAttachments
(
sub_id
);
})
.
push
(
function
(
result
)
{
var
attachment_id
,
attachments
=
{},
mapping_dict
=
{},
i
;
for
(
attachment_id
in
storage
.
_attachment_mapping_dict
)
{
if
(
storage
.
_attachment_mapping_dict
.
hasOwnProperty
(
attachment_id
))
{
mapping_dict
[
getAttachmentId
(
storage
,
sub_id
,
attachment_id
,
"
get
"
)]
=
attachment_id
;
}
}
for
(
attachment_id
in
result
)
{
if
(
result
.
hasOwnProperty
(
attachment_id
))
{
if
(
!
(
storage
.
_attachment_list
.
length
>
0
&&
storage
.
_attachment_list
.
indexOf
(
attachment_id
)
<
0
))
{
if
(
mapping_dict
.
hasOwnProperty
(
attachment_id
))
{
attachments
[
mapping_dict
[
attachment_id
]]
=
{};
}
else
{
attachments
[
attachment_id
]
=
{};
}
}
}
}
for
(
i
=
0
;
i
<
storage
.
_attachment_list
.
length
;
i
+=
1
)
{
if
(
!
attachments
.
hasOwnProperty
(
storage
.
_attachment_list
[
i
]))
{
attachments
[
storage
.
_attachment_list
[
i
]]
=
{};
}
}
return
attachments
;
});
};
MappingStorage
.
prototype
.
hasCapacity
=
function
(
name
)
{
return
this
.
_sub_storage
.
hasCapacity
(
name
);
};
MappingStorage
.
prototype
.
repair
=
function
()
{
return
this
.
_sub_storage
.
repair
.
apply
(
this
.
_sub_storage
,
arguments
);
};
MappingStorage
.
prototype
.
bulk
=
function
(
id_list
)
{
var
storage
=
this
;
function
mapId
(
parameter
)
{
return
getSubStorageId
(
storage
,
parameter
.
parameter_list
[
0
])
.
push
(
function
(
id
)
{
return
{
"
method
"
:
parameter
.
method
,
"
parameter_list
"
:
[
id
]};
});
}
return
new
RSVP
.
Queue
()
.
push
(
function
()
{
var
promise_list
=
id_list
.
map
(
mapId
);
return
RSVP
.
all
(
promise_list
);
})
.
push
(
function
(
id_list_mapped
)
{
return
storage
.
_sub_storage
.
bulk
(
id_list_mapped
);
})
.
push
(
function
(
result
)
{
var
mapped_result
=
[],
i
;
for
(
i
=
0
;
i
<
result
.
length
;
i
+=
1
)
{
mapped_result
.
push
(
mapToMainDocument
(
storage
,
result
[
i
]
));
}
return
mapped_result
;
});
};
MappingStorage
.
prototype
.
buildQuery
=
function
(
option
)
{
var
storage
=
this
,
i
,
query
,
property
,
select_list
=
[],
sort_on
=
[];
function
mapQuery
(
one_query
)
{
var
j
,
query_list
=
[],
key
,
sub_query
;
if
(
one_query
.
type
===
"
complex
"
)
{
for
(
j
=
0
;
j
<
one_query
.
query_list
.
length
;
j
+=
1
)
{
sub_query
=
mapQuery
(
one_query
.
query_list
[
j
]);
if
(
sub_query
)
{
query_list
.
push
(
sub_query
);
}
}
one_query
.
query_list
=
query_list
;
return
one_query
;
}
key
=
mapToMainProperty
(
storage
,
one_query
.
key
,
{},
{});
if
(
key
!==
undefined
)
{
one_query
.
key
=
key
;
return
one_query
;
}
return
false
;
}
if
(
option
.
sort_on
!==
undefined
)
{
for
(
i
=
0
;
i
<
option
.
sort_on
.
length
;
i
+=
1
)
{
property
=
mapToMainProperty
(
this
,
option
.
sort_on
[
i
][
0
],
{},
{});
if
(
property
&&
sort_on
.
indexOf
(
property
)
<
0
)
{
sort_on
.
push
([
property
,
option
.
sort_on
[
i
][
1
]]);
}
}
}
if
(
this
.
_query
.
sort_on
!==
undefined
)
{
for
(
i
=
0
;
i
<
this
.
_query
.
sort_on
.
length
;
i
+=
1
)
{
property
=
mapToMainProperty
(
this
,
this
.
_query
.
sort_on
[
i
],
{},
{});
if
(
sort_on
.
indexOf
(
property
)
<
0
)
{
sort_on
.
push
([
property
,
option
.
sort_on
[
i
][
1
]]);
}
}
}
if
(
option
.
select_list
!==
undefined
)
{
for
(
i
=
0
;
i
<
option
.
select_list
.
length
;
i
+=
1
)
{
property
=
mapToMainProperty
(
this
,
option
.
select_list
[
i
],
{},
{});
if
(
property
&&
select_list
.
indexOf
(
property
)
<
0
)
{
select_list
.
push
(
property
);
}
}
}
if
(
this
.
_query
.
select_list
!==
undefined
)
{
for
(
i
=
0
;
i
<
this
.
_query
.
select_list
;
i
+=
1
)
{
property
=
this
.
_query
.
select_list
[
i
];
if
(
select_list
.
indexOf
(
property
)
<
0
)
{
select_list
.
push
(
property
);
}
}
}
if
(
this
.
_id_mapped
)
{
// modify here for future way to map id
select_list
.
push
(
this
.
_id_mapped
);
}
if
(
option
.
query
!==
undefined
)
{
query
=
mapQuery
(
QueryFactory
.
create
(
option
.
query
));
}
if
(
this
.
_query
.
query
!==
undefined
)
{
if
(
query
===
undefined
)
{
query
=
this
.
_query
.
query
;
}
query
=
new
ComplexQuery
({
operator
:
"
AND
"
,
query_list
:
[
query
,
this
.
_query
.
query
],
type
:
"
complex
"
});
}
if
(
query
!==
undefined
)
{
query
=
Query
.
objectToSearchText
(
query
);
}
return
this
.
_sub_storage
.
allDocs
(
{
query
:
query
,
select_list
:
select_list
,
sort_on
:
sort_on
,
limit
:
option
.
limit
}
)
.
push
(
function
(
result
)
{
var
sub_doc
,
map_info
=
storage
.
_map_id
||
[
"
equalSubId
"
];
for
(
i
=
0
;
i
<
result
.
data
.
total_rows
;
i
+=
1
)
{
sub_doc
=
result
.
data
.
rows
[
i
].
value
;
result
.
data
.
rows
[
i
].
id
=
mapping_function
[
map_info
[
0
]].
mapToId
(
storage
,
sub_doc
,
result
.
data
.
rows
[
i
].
id
,
map_info
[
1
]
);
result
.
data
.
rows
[
i
].
value
=
mapToMainDocument
(
storage
,
sub_doc
);
}
return
result
.
data
.
rows
;
});
};
jIO
.
addStorage
(
'
mapping
'
,
MappingStorage
);
}(
jIO
,
RSVP
,
UriTemplate
,
SimpleQuery
,
ComplexQuery
,
QueryFactory
,
Query
,
FormData
));
module
=
node_module
;
module
=
node_module
;
jIO
.
node_env
=
window
;
jIO
.
node_env
=
window
;
...
...
dist/jio-latest.js
View file @
d57087fe
...
@@ -6274,7 +6274,6 @@ parse: function parse(input) {
...
@@ -6274,7 +6274,6 @@ parse: function parse(input) {
vstack
.
length
=
vstack
.
length
-
n
;
vstack
.
length
=
vstack
.
length
-
n
;
lstack
.
length
=
lstack
.
length
-
n
;
lstack
.
length
=
lstack
.
length
-
n
;
}
}
_token_stack
:
var
lex
=
function
()
{
var
lex
=
function
()
{
var
token
;
var
token
;
token
=
lexer
.
lex
()
||
EOF
;
token
=
lexer
.
lex
()
||
EOF
;
...
@@ -14916,13 +14915,19 @@ return new Parser;
...
@@ -14916,13 +14915,19 @@ return new Parser;
}
}
function
waitForOpenIndexedDB
(
db_name
,
callback
)
{
function
waitForOpenIndexedDB
(
db_name
,
callback
)
{
var
request
;
function
canceller
()
{
if
((
request
!==
undefined
)
&&
(
request
.
result
!==
undefined
))
{
request
.
result
.
close
();
}
}
function
resolver
(
resolve
,
reject
)
{
function
resolver
(
resolve
,
reject
)
{
// Open DB //
// Open DB //
var
request
=
indexedDB
.
open
(
db_name
);
request
=
indexedDB
.
open
(
db_name
);
request
.
onerror
=
function
(
error
)
{
request
.
onerror
=
function
(
error
)
{
if
(
request
.
result
)
{
canceller
();
request
.
result
.
close
();
}
if
((
error
!==
undefined
)
&&
if
((
error
!==
undefined
)
&&
(
error
.
target
instanceof
IDBOpenDBRequest
)
&&
(
error
.
target
instanceof
IDBOpenDBRequest
)
&&
(
error
.
target
.
error
instanceof
DOMError
))
{
(
error
.
target
.
error
instanceof
DOMError
))
{
...
@@ -14934,17 +14939,16 @@ return new Parser;
...
@@ -14934,17 +14939,16 @@ return new Parser;
};
};
request
.
onabort
=
function
()
{
request
.
onabort
=
function
()
{
request
.
result
.
close
();
canceller
();
reject
(
"
Aborting connection to:
"
+
db_name
);
reject
(
"
Aborting connection to:
"
+
db_name
);
};
};
request
.
ontimeout
=
function
()
{
request
.
ontimeout
=
function
()
{
request
.
result
.
close
();
reject
(
"
Connection to:
"
+
db_name
+
"
timeout
"
);
reject
(
"
Connection to:
"
+
db_name
+
"
timeout
"
);
};
};
request
.
onblocked
=
function
()
{
request
.
onblocked
=
function
()
{
request
.
result
.
close
();
canceller
();
reject
(
"
Connection to:
"
+
db_name
+
"
was blocked
"
);
reject
(
"
Connection to:
"
+
db_name
+
"
was blocked
"
);
};
};
...
@@ -14952,26 +14956,32 @@ return new Parser;
...
@@ -14952,26 +14956,32 @@ return new Parser;
request
.
onupgradeneeded
=
handleUpgradeNeeded
;
request
.
onupgradeneeded
=
handleUpgradeNeeded
;
request
.
onversionchange
=
function
()
{
request
.
onversionchange
=
function
()
{
request
.
result
.
close
();
canceller
();
reject
(
db_name
+
"
was upgraded
"
);
reject
(
db_name
+
"
was upgraded
"
);
};
};
request
.
onsuccess
=
function
()
{
request
.
onsuccess
=
function
()
{
var
result
;
try
{
result
=
callback
(
request
.
result
);
}
catch
(
error
)
{
reject
(
error
);
}
return
new
RSVP
.
Queue
()
return
new
RSVP
.
Queue
()
.
push
(
function
()
{
.
push
(
function
()
{
return
callback
(
request
.
result
)
;
return
result
;
})
})
.
push
(
function
(
result
)
{
.
push
(
function
(
final_
result
)
{
request
.
result
.
close
();
canceller
();
resolve
(
result
);
resolve
(
final_
result
);
},
function
(
error
)
{
},
function
(
error
)
{
request
.
result
.
close
();
canceller
();
reject
(
error
);
reject
(
error
);
});
});
};
};
}
}
return
new
RSVP
.
Promise
(
resolver
);
return
new
RSVP
.
Promise
(
resolver
,
canceller
);
}
}
function
waitForTransaction
(
db
,
stores
,
flag
,
callback
)
{
function
waitForTransaction
(
db
,
stores
,
flag
,
callback
)
{
...
@@ -15001,14 +15011,8 @@ return new Parser;
...
@@ -15001,14 +15011,8 @@ return new Parser;
reject
(
error
);
reject
(
error
);
});
});
};
};
tx
.
onerror
=
function
(
error
)
{
tx
.
onerror
=
reject
;
canceller
();
tx
.
onabort
=
reject
;
reject
(
error
);
};
tx
.
onabort
=
function
(
evt
)
{
reject
(
evt
.
target
);
};
return
tx
;
}
}
return
new
RSVP
.
Promise
(
resolver
,
canceller
);
return
new
RSVP
.
Promise
(
resolver
,
canceller
);
}
}
...
@@ -15985,3 +15989,659 @@ return new Parser;
...
@@ -15985,3 +15989,659 @@ return new Parser;
jIO
.
addStorage
(
'
cloudooo
'
,
CloudoooStorage
);
jIO
.
addStorage
(
'
cloudooo
'
,
CloudoooStorage
);
}(
jIO
,
RSVP
,
DOMParser
,
XMLSerializer
));
}(
jIO
,
RSVP
,
DOMParser
,
XMLSerializer
));
/*jslint indent:2, maxlen: 80, nomen: true */
/*global jIO, RSVP, UriTemplate, SimpleQuery, ComplexQuery, QueryFactory,
Query, FormData*/
(
function
(
jIO
,
RSVP
,
UriTemplate
,
SimpleQuery
,
ComplexQuery
,
QueryFactory
,
Query
,
FormData
)
{
"
use strict
"
;
function
getSubIdEqualSubProperty
(
storage
,
value
,
key
)
{
var
query
;
if
(
storage
.
_no_sub_query_id
)
{
throw
new
jIO
.
util
.
jIOError
(
'
no sub query id active
'
,
404
);
}
if
(
!
value
)
{
throw
new
jIO
.
util
.
jIOError
(
'
can not find document with
'
+
key
+
'
: undefined
'
,
404
);
}
if
(
storage
.
_mapping_id_memory_dict
[
value
])
{
return
storage
.
_mapping_id_memory_dict
[
value
];
}
query
=
new
SimpleQuery
({
key
:
key
,
value
:
value
,
type
:
"
simple
"
});
if
(
storage
.
_query
.
query
!==
undefined
)
{
query
=
new
ComplexQuery
({
operator
:
"
AND
"
,
query_list
:
[
query
,
storage
.
_query
.
query
],
type
:
"
complex
"
});
}
query
=
Query
.
objectToSearchText
(
query
);
return
storage
.
_sub_storage
.
allDocs
({
"
query
"
:
query
,
"
sort_on
"
:
storage
.
_query
.
sort_on
,
"
select_list
"
:
storage
.
_query
.
select_list
,
"
limit
"
:
storage
.
_query
.
limit
})
.
push
(
function
(
data
)
{
if
(
data
.
data
.
total_rows
===
0
)
{
throw
new
jIO
.
util
.
jIOError
(
"
Can not find document with (
"
+
key
+
"
,
"
+
value
+
"
)
"
,
404
);
}
if
(
data
.
data
.
total_rows
>
1
)
{
throw
new
TypeError
(
"
id must be unique field:
"
+
key
+
"
, result:
"
+
data
.
data
.
rows
.
toString
());
}
storage
.
_mapping_id_memory_dict
[
value
]
=
data
.
data
.
rows
[
0
].
id
;
return
data
.
data
.
rows
[
0
].
id
;
});
}
/*jslint unparam: true*/
var
mapping_function
=
{
"
equalSubProperty
"
:
{
"
mapToSubProperty
"
:
function
(
property
,
sub_doc
,
doc
,
args
,
id
)
{
sub_doc
[
args
]
=
doc
[
property
];
return
args
;
},
"
mapToMainProperty
"
:
function
(
property
,
sub_doc
,
doc
,
args
,
sub_id
)
{
if
(
sub_doc
.
hasOwnProperty
(
args
))
{
doc
[
property
]
=
sub_doc
[
args
];
}
return
args
;
},
"
mapToSubId
"
:
function
(
storage
,
doc
,
id
,
args
)
{
if
(
doc
!==
undefined
)
{
if
(
storage
.
_property_for_sub_id
&&
doc
.
hasOwnProperty
(
storage
.
_property_for_sub_id
))
{
return
doc
[
storage
.
_property_for_sub_id
];
}
}
return
getSubIdEqualSubProperty
(
storage
,
id
,
storage
.
_map_id
[
1
]);
},
"
mapToId
"
:
function
(
storage
,
sub_doc
,
sub_id
,
args
)
{
return
sub_doc
[
args
];
}
},
"
equalValue
"
:
{
"
mapToSubProperty
"
:
function
(
property
,
sub_doc
,
doc
,
args
)
{
sub_doc
[
property
]
=
args
;
return
property
;
},
"
mapToMainProperty
"
:
function
(
property
)
{
return
property
;
}
},
"
ignore
"
:
{
"
mapToSubProperty
"
:
function
()
{
return
false
;
},
"
mapToMainProperty
"
:
function
(
property
)
{
return
property
;
}
},
"
equalSubId
"
:
{
"
mapToSubProperty
"
:
function
(
property
,
sub_doc
,
doc
)
{
sub_doc
[
property
]
=
doc
[
property
];
return
property
;
},
"
mapToMainProperty
"
:
function
(
property
,
sub_doc
,
doc
,
args
,
sub_id
)
{
if
(
sub_id
===
undefined
&&
sub_doc
.
hasOwnProperty
(
property
))
{
doc
[
property
]
=
sub_doc
[
property
];
}
else
{
doc
[
property
]
=
sub_id
;
}
return
property
;
},
"
mapToSubId
"
:
function
(
storage
,
doc
,
id
,
args
)
{
return
id
;
},
"
mapToId
"
:
function
(
storage
,
sub_doc
,
sub_id
)
{
return
sub_id
;
}
},
"
keep
"
:
{
"
mapToSubProperty
"
:
function
(
property
,
sub_doc
,
doc
)
{
sub_doc
[
property
]
=
doc
[
property
];
return
property
;
},
"
mapToMainProperty
"
:
function
(
property
,
sub_doc
,
doc
)
{
doc
[
property
]
=
sub_doc
[
property
];
return
property
;
}
},
"
switchPropertyValue
"
:
{
"
mapToSubProperty
"
:
function
(
property
,
sub_doc
,
doc
,
args
)
{
sub_doc
[
args
[
0
]]
=
args
[
1
][
doc
[
property
]];
return
args
[
0
];
},
"
mapToMainProperty
"
:
function
(
property
,
sub_doc
,
doc
,
args
)
{
var
subvalue
,
value
=
sub_doc
[
args
[
0
]];
for
(
subvalue
in
args
[
1
])
{
if
(
args
[
1
].
hasOwnProperty
(
subvalue
))
{
if
(
value
===
args
[
1
][
subvalue
])
{
doc
[
property
]
=
subvalue
;
return
property
;
}
}
}
}
}
};
/*jslint unparam: false*/
function
initializeQueryAndDefaultMapping
(
storage
)
{
var
property
,
query_list
=
[];
for
(
property
in
storage
.
_mapping_dict
)
{
if
(
storage
.
_mapping_dict
.
hasOwnProperty
(
property
))
{
if
(
storage
.
_mapping_dict
[
property
][
0
]
===
"
equalValue
"
)
{
if
(
storage
.
_mapping_dict
[
property
][
1
]
===
undefined
)
{
throw
new
jIO
.
util
.
jIOError
(
"
equalValue has not parameter
"
,
400
);
}
storage
.
_default_mapping
[
property
]
=
storage
.
_mapping_dict
[
property
][
1
];
query_list
.
push
(
new
SimpleQuery
({
key
:
property
,
value
:
storage
.
_mapping_dict
[
property
][
1
],
type
:
"
simple
"
}));
}
if
(
storage
.
_mapping_dict
[
property
][
0
]
===
"
equalSubId
"
)
{
if
(
storage
.
_property_for_sub_id
!==
undefined
)
{
throw
new
jIO
.
util
.
jIOError
(
"
equalSubId can be defined one time
"
,
400
);
}
storage
.
_property_for_sub_id
=
property
;
}
}
}
if
(
storage
.
_map_id
[
0
]
===
"
equalSubProperty
"
)
{
storage
.
_mapping_dict
[
storage
.
_map_id
[
1
]]
=
[
"
keep
"
];
}
if
(
storage
.
_query
.
query
!==
undefined
)
{
query_list
.
push
(
QueryFactory
.
create
(
storage
.
_query
.
query
));
}
if
(
query_list
.
length
>
1
)
{
storage
.
_query
.
query
=
new
ComplexQuery
({
type
:
"
complex
"
,
query_list
:
query_list
,
operator
:
"
AND
"
});
}
else
if
(
query_list
.
length
===
1
)
{
storage
.
_query
.
query
=
query_list
[
0
];
}
}
function
MappingStorage
(
spec
)
{
this
.
_mapping_dict
=
spec
.
property
||
{};
this
.
_sub_storage
=
jIO
.
createJIO
(
spec
.
sub_storage
);
this
.
_map_all_property
=
spec
.
map_all_property
!==
undefined
?
spec
.
map_all_property
:
true
;
this
.
_no_sub_query_id
=
spec
.
no_sub_query_id
;
this
.
_attachment_mapping_dict
=
spec
.
attachment
||
{};
this
.
_query
=
spec
.
query
||
{};
this
.
_map_id
=
spec
.
id
||
[
"
equalSubId
"
];
this
.
_id_mapped
=
(
spec
.
id
!==
undefined
)
?
spec
.
id
[
1
]
:
false
;
if
(
this
.
_query
.
query
!==
undefined
)
{
this
.
_query
.
query
=
QueryFactory
.
create
(
this
.
_query
.
query
);
}
this
.
_default_mapping
=
{};
this
.
_mapping_id_memory_dict
=
{};
this
.
_attachment_list
=
spec
.
attachment_list
||
[];
this
.
_caching_dict
=
{
id
:
{}};
initializeQueryAndDefaultMapping
(
this
);
}
function
getAttachmentId
(
storage
,
sub_id
,
attachment_id
,
method
)
{
var
mapping_dict
=
storage
.
_attachment_mapping_dict
;
if
(
mapping_dict
!==
undefined
&&
mapping_dict
[
attachment_id
]
!==
undefined
&&
mapping_dict
[
attachment_id
][
method
]
!==
undefined
&&
mapping_dict
[
attachment_id
][
method
].
uri_template
!==
undefined
)
{
return
UriTemplate
.
parse
(
mapping_dict
[
attachment_id
][
method
].
uri_template
).
expand
({
id
:
sub_id
});
}
return
attachment_id
;
}
function
getSubStorageId
(
storage
,
id
,
doc
)
{
if
(
storage
.
_caching_dict
.
id
.
hasOwnProperty
(
id
))
{
return
new
RSVP
.
Queue
()
.
push
(
function
()
{
return
storage
.
_caching_dict
.
id
[
id
];
});
}
return
new
RSVP
.
Queue
()
.
push
(
function
()
{
var
map_info
=
storage
.
_map_id
||
[
"
equalSubId
"
];
if
(
storage
.
_property_for_sub_id
&&
doc
!==
undefined
&&
doc
.
hasOwnProperty
(
storage
.
_property_for_sub_id
))
{
return
doc
[
storage
.
_property_for_sub_id
];
}
return
mapping_function
[
map_info
[
0
]].
mapToSubId
(
storage
,
doc
,
id
,
map_info
[
1
]
);
})
.
push
(
function
(
sub_id
)
{
storage
.
_caching_dict
.
id
[
id
]
=
sub_id
;
return
sub_id
;
});
}
function
mapToSubProperty
(
storage
,
property
,
sub_doc
,
doc
,
id
)
{
var
mapping_info
=
storage
.
_mapping_dict
[
property
]
||
[
"
keep
"
];
return
mapping_function
[
mapping_info
[
0
]].
mapToSubProperty
(
property
,
sub_doc
,
doc
,
mapping_info
[
1
],
id
);
}
function
mapToMainProperty
(
storage
,
property
,
sub_doc
,
doc
,
sub_id
)
{
var
mapping_info
=
storage
.
_mapping_dict
[
property
]
||
[
"
keep
"
];
return
mapping_function
[
mapping_info
[
0
]].
mapToMainProperty
(
property
,
sub_doc
,
doc
,
mapping_info
[
1
],
sub_id
);
}
function
mapToMainDocument
(
storage
,
sub_doc
,
sub_id
)
{
var
doc
=
{},
property
,
property_list
=
[
storage
.
_id_mapped
];
for
(
property
in
storage
.
_mapping_dict
)
{
if
(
storage
.
_mapping_dict
.
hasOwnProperty
(
property
))
{
property_list
.
push
(
mapToMainProperty
(
storage
,
property
,
sub_doc
,
doc
,
sub_id
));
}
}
if
(
storage
.
_map_all_property
)
{
for
(
property
in
sub_doc
)
{
if
(
sub_doc
.
hasOwnProperty
(
property
))
{
if
(
property_list
.
indexOf
(
property
)
<
0
)
{
doc
[
property
]
=
sub_doc
[
property
];
}
}
}
}
if
(
storage
.
_map_for_sub_storage_id
!==
undefined
)
{
doc
[
storage
.
_map_for_sub_storage_id
]
=
sub_id
;
}
return
doc
;
}
function
mapToSubstorageDocument
(
storage
,
doc
,
id
)
{
var
sub_doc
=
{},
property
;
for
(
property
in
doc
)
{
if
(
doc
.
hasOwnProperty
(
property
))
{
mapToSubProperty
(
storage
,
property
,
sub_doc
,
doc
,
id
);
}
}
for
(
property
in
storage
.
_default_mapping
)
{
if
(
storage
.
_default_mapping
.
hasOwnProperty
(
property
))
{
sub_doc
[
property
]
=
storage
.
_default_mapping
[
property
];
}
}
if
(
storage
.
_map_id
[
0
]
===
"
equalSubProperty
"
&&
id
!==
undefined
)
{
sub_doc
[
storage
.
_map_id
[
1
]]
=
id
;
}
return
sub_doc
;
}
function
handleAttachment
(
storage
,
argument_list
,
method
)
{
return
getSubStorageId
(
storage
,
argument_list
[
0
])
.
push
(
function
(
sub_id
)
{
argument_list
[
0
]
=
sub_id
;
var
old_id
=
argument_list
[
1
];
argument_list
[
1
]
=
getAttachmentId
(
storage
,
argument_list
[
0
],
argument_list
[
1
],
method
);
if
(
storage
.
_attachment_list
.
length
>
0
&&
storage
.
_attachment_list
.
indexOf
(
old_id
)
<
0
)
{
if
(
method
===
"
get
"
)
{
throw
new
jIO
.
util
.
jIOError
(
"
unhautorized attachment
"
,
404
);
}
return
;
}
return
storage
.
_sub_storage
[
method
+
"
Attachment
"
].
apply
(
storage
.
_sub_storage
,
argument_list
);
});
}
MappingStorage
.
prototype
.
get
=
function
(
id
)
{
var
storage
=
this
;
return
getSubStorageId
(
this
,
id
)
.
push
(
function
(
sub_id
)
{
return
storage
.
_sub_storage
.
get
(
sub_id
)
.
push
(
function
(
sub_doc
)
{
return
mapToMainDocument
(
storage
,
sub_doc
,
sub_id
);
});
});
};
MappingStorage
.
prototype
.
post
=
function
(
doc
)
{
var
sub_doc
=
mapToSubstorageDocument
(
this
,
doc
),
id
=
doc
[
this
.
_property_for_sub_id
],
storage
=
this
;
if
(
this
.
_property_for_sub_id
&&
id
!==
undefined
)
{
return
this
.
_sub_storage
.
put
(
id
,
sub_doc
);
}
if
(
this
.
_id_mapped
&&
doc
[
this
.
_id_mapped
]
!==
undefined
)
{
return
getSubStorageId
(
storage
,
id
,
doc
)
.
push
(
function
(
sub_id
)
{
return
storage
.
_sub_storage
.
put
(
sub_id
,
sub_doc
);
})
.
push
(
function
()
{
return
doc
[
storage
.
_id_mapped
];
})
.
push
(
undefined
,
function
(
error
)
{
if
(
error
instanceof
jIO
.
util
.
jIOError
)
{
return
storage
.
_sub_storage
.
post
(
sub_doc
);
}
throw
error
;
});
}
throw
new
jIO
.
util
.
jIOError
(
"
post is not supported with id mapped
"
,
400
);
};
MappingStorage
.
prototype
.
put
=
function
(
id
,
doc
)
{
var
storage
=
this
,
sub_doc
=
mapToSubstorageDocument
(
this
,
doc
,
id
);
return
getSubStorageId
(
this
,
id
,
doc
)
.
push
(
function
(
sub_id
)
{
return
storage
.
_sub_storage
.
put
(
sub_id
,
sub_doc
);
})
.
push
(
undefined
,
function
(
error
)
{
if
(
error
instanceof
jIO
.
util
.
jIOError
&&
error
.
status_code
===
404
)
{
return
storage
.
_sub_storage
.
post
(
sub_doc
);
}
throw
error
;
})
.
push
(
function
()
{
return
id
;
});
};
MappingStorage
.
prototype
.
remove
=
function
(
id
)
{
var
storage
=
this
;
return
getSubStorageId
(
this
,
id
)
.
push
(
function
(
sub_id
)
{
return
storage
.
_sub_storage
.
remove
(
sub_id
);
})
.
push
(
function
()
{
return
id
;
});
};
MappingStorage
.
prototype
.
getAttachment
=
function
()
{
return
handleAttachment
(
this
,
arguments
,
"
get
"
);
};
MappingStorage
.
prototype
.
putAttachment
=
function
(
id
,
attachment_id
,
blob
)
{
var
storage
=
this
,
mapping_dict
=
storage
.
_attachment_mapping_dict
;
// THIS IS REALLY BAD, FIND AN OTHER WAY IN FUTURE
if
(
mapping_dict
!==
undefined
&&
mapping_dict
[
attachment_id
]
!==
undefined
&&
mapping_dict
[
attachment_id
].
put
!==
undefined
&&
mapping_dict
[
attachment_id
].
put
.
erp5_put_template
!==
undefined
)
{
return
getSubStorageId
(
storage
,
id
)
.
push
(
function
(
sub_id
)
{
var
url
=
UriTemplate
.
parse
(
mapping_dict
[
attachment_id
].
put
.
erp5_put_template
).
expand
({
id
:
sub_id
}),
data
=
new
FormData
();
data
.
append
(
"
field_my_file
"
,
blob
);
data
.
append
(
"
form_id
"
,
"
File_view
"
);
return
jIO
.
util
.
ajax
({
"
type
"
:
"
POST
"
,
"
url
"
:
url
,
"
data
"
:
data
,
"
xhrFields
"
:
{
withCredentials
:
true
}
});
});
}
return
handleAttachment
(
this
,
arguments
,
"
put
"
,
id
)
.
push
(
function
()
{
return
attachment_id
;
});
};
MappingStorage
.
prototype
.
removeAttachment
=
function
(
id
,
attachment_id
)
{
return
handleAttachment
(
this
,
arguments
,
"
remove
"
,
id
)
.
push
(
function
()
{
return
attachment_id
;
});
};
MappingStorage
.
prototype
.
allAttachments
=
function
(
id
)
{
var
storage
=
this
,
sub_id
;
return
getSubStorageId
(
storage
,
id
)
.
push
(
function
(
sub_id_result
)
{
sub_id
=
sub_id_result
;
return
storage
.
_sub_storage
.
allAttachments
(
sub_id
);
})
.
push
(
function
(
result
)
{
var
attachment_id
,
attachments
=
{},
mapping_dict
=
{},
i
;
for
(
attachment_id
in
storage
.
_attachment_mapping_dict
)
{
if
(
storage
.
_attachment_mapping_dict
.
hasOwnProperty
(
attachment_id
))
{
mapping_dict
[
getAttachmentId
(
storage
,
sub_id
,
attachment_id
,
"
get
"
)]
=
attachment_id
;
}
}
for
(
attachment_id
in
result
)
{
if
(
result
.
hasOwnProperty
(
attachment_id
))
{
if
(
!
(
storage
.
_attachment_list
.
length
>
0
&&
storage
.
_attachment_list
.
indexOf
(
attachment_id
)
<
0
))
{
if
(
mapping_dict
.
hasOwnProperty
(
attachment_id
))
{
attachments
[
mapping_dict
[
attachment_id
]]
=
{};
}
else
{
attachments
[
attachment_id
]
=
{};
}
}
}
}
for
(
i
=
0
;
i
<
storage
.
_attachment_list
.
length
;
i
+=
1
)
{
if
(
!
attachments
.
hasOwnProperty
(
storage
.
_attachment_list
[
i
]))
{
attachments
[
storage
.
_attachment_list
[
i
]]
=
{};
}
}
return
attachments
;
});
};
MappingStorage
.
prototype
.
hasCapacity
=
function
(
name
)
{
return
this
.
_sub_storage
.
hasCapacity
(
name
);
};
MappingStorage
.
prototype
.
repair
=
function
()
{
return
this
.
_sub_storage
.
repair
.
apply
(
this
.
_sub_storage
,
arguments
);
};
MappingStorage
.
prototype
.
bulk
=
function
(
id_list
)
{
var
storage
=
this
;
function
mapId
(
parameter
)
{
return
getSubStorageId
(
storage
,
parameter
.
parameter_list
[
0
])
.
push
(
function
(
id
)
{
return
{
"
method
"
:
parameter
.
method
,
"
parameter_list
"
:
[
id
]};
});
}
return
new
RSVP
.
Queue
()
.
push
(
function
()
{
var
promise_list
=
id_list
.
map
(
mapId
);
return
RSVP
.
all
(
promise_list
);
})
.
push
(
function
(
id_list_mapped
)
{
return
storage
.
_sub_storage
.
bulk
(
id_list_mapped
);
})
.
push
(
function
(
result
)
{
var
mapped_result
=
[],
i
;
for
(
i
=
0
;
i
<
result
.
length
;
i
+=
1
)
{
mapped_result
.
push
(
mapToMainDocument
(
storage
,
result
[
i
]
));
}
return
mapped_result
;
});
};
MappingStorage
.
prototype
.
buildQuery
=
function
(
option
)
{
var
storage
=
this
,
i
,
query
,
property
,
select_list
=
[],
sort_on
=
[];
function
mapQuery
(
one_query
)
{
var
j
,
query_list
=
[],
key
,
sub_query
;
if
(
one_query
.
type
===
"
complex
"
)
{
for
(
j
=
0
;
j
<
one_query
.
query_list
.
length
;
j
+=
1
)
{
sub_query
=
mapQuery
(
one_query
.
query_list
[
j
]);
if
(
sub_query
)
{
query_list
.
push
(
sub_query
);
}
}
one_query
.
query_list
=
query_list
;
return
one_query
;
}
key
=
mapToMainProperty
(
storage
,
one_query
.
key
,
{},
{});
if
(
key
!==
undefined
)
{
one_query
.
key
=
key
;
return
one_query
;
}
return
false
;
}
if
(
option
.
sort_on
!==
undefined
)
{
for
(
i
=
0
;
i
<
option
.
sort_on
.
length
;
i
+=
1
)
{
property
=
mapToMainProperty
(
this
,
option
.
sort_on
[
i
][
0
],
{},
{});
if
(
property
&&
sort_on
.
indexOf
(
property
)
<
0
)
{
sort_on
.
push
([
property
,
option
.
sort_on
[
i
][
1
]]);
}
}
}
if
(
this
.
_query
.
sort_on
!==
undefined
)
{
for
(
i
=
0
;
i
<
this
.
_query
.
sort_on
.
length
;
i
+=
1
)
{
property
=
mapToMainProperty
(
this
,
this
.
_query
.
sort_on
[
i
],
{},
{});
if
(
sort_on
.
indexOf
(
property
)
<
0
)
{
sort_on
.
push
([
property
,
option
.
sort_on
[
i
][
1
]]);
}
}
}
if
(
option
.
select_list
!==
undefined
)
{
for
(
i
=
0
;
i
<
option
.
select_list
.
length
;
i
+=
1
)
{
property
=
mapToMainProperty
(
this
,
option
.
select_list
[
i
],
{},
{});
if
(
property
&&
select_list
.
indexOf
(
property
)
<
0
)
{
select_list
.
push
(
property
);
}
}
}
if
(
this
.
_query
.
select_list
!==
undefined
)
{
for
(
i
=
0
;
i
<
this
.
_query
.
select_list
;
i
+=
1
)
{
property
=
this
.
_query
.
select_list
[
i
];
if
(
select_list
.
indexOf
(
property
)
<
0
)
{
select_list
.
push
(
property
);
}
}
}
if
(
this
.
_id_mapped
)
{
// modify here for future way to map id
select_list
.
push
(
this
.
_id_mapped
);
}
if
(
option
.
query
!==
undefined
)
{
query
=
mapQuery
(
QueryFactory
.
create
(
option
.
query
));
}
if
(
this
.
_query
.
query
!==
undefined
)
{
if
(
query
===
undefined
)
{
query
=
this
.
_query
.
query
;
}
query
=
new
ComplexQuery
({
operator
:
"
AND
"
,
query_list
:
[
query
,
this
.
_query
.
query
],
type
:
"
complex
"
});
}
if
(
query
!==
undefined
)
{
query
=
Query
.
objectToSearchText
(
query
);
}
return
this
.
_sub_storage
.
allDocs
(
{
query
:
query
,
select_list
:
select_list
,
sort_on
:
sort_on
,
limit
:
option
.
limit
}
)
.
push
(
function
(
result
)
{
var
sub_doc
,
map_info
=
storage
.
_map_id
||
[
"
equalSubId
"
];
for
(
i
=
0
;
i
<
result
.
data
.
total_rows
;
i
+=
1
)
{
sub_doc
=
result
.
data
.
rows
[
i
].
value
;
result
.
data
.
rows
[
i
].
id
=
mapping_function
[
map_info
[
0
]].
mapToId
(
storage
,
sub_doc
,
result
.
data
.
rows
[
i
].
id
,
map_info
[
1
]
);
result
.
data
.
rows
[
i
].
value
=
mapToMainDocument
(
storage
,
sub_doc
);
}
return
result
.
data
.
rows
;
});
};
jIO
.
addStorage
(
'
mapping
'
,
MappingStorage
);
}(
jIO
,
RSVP
,
UriTemplate
,
SimpleQuery
,
ComplexQuery
,
QueryFactory
,
Query
,
FormData
));
\ No newline at end of file
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment