coffeescript - JSON will not insert into Meteor Collection (even with Fiber or bindEnvironment) -



coffeescript - JSON will not insert into Meteor Collection (even with Fiber or bindEnvironment) -

i realize similar topics have been discussed, have browsed through them , tried mimic solutions 4 hours none of them seem solve problem. not have posted having exhausted potential solution find.

i trying convert big csv json , insert meteor collection next conversion.

here code using meteor.bindelement approach:

if meteor.isserver @fiber = meteor.npmrequire("fibers") meteor.startup -> #converter class if data.find().count() 0 converter = meteor.npmrequire('csvtojson').core.converter fs = meteor.npmrequire('fs') csvfilename = '/path/to/my/file.csv' filestream = fs.createreadstream(csvfilename) #new converter instance csvconverter = new converter(constructresult: true) #end_parsed emitted 1 time parsing finished csvconverter.on "end_parsed", (jsonobj) -> console.log jsonobj boundfunction = meteor.bindenvironment(-> data.insert jsonobj homecoming , (e) -> throw e homecoming ) inserttodb boundfunction #read file filestream.pipe csvconverter homecoming

after parsing able log json fine when seek add together collection this:

csvconverter.on "end_parsed", (jsonobj) -> console.log jsonobj data.insert jsonobj

i error:

throw new error("meteor code must run within fiber. " + w20141112-20:08:44.306(-8)? (stderr) ^ w20141112-20:08:44.306(-8)? (stderr) error: meteor code must run within fiber. seek wrapping callbacks pass non-meteor libraries meteor.bindenvironment. w20141112-20:08:44.306(-8)? (stderr) @ object.meteor._nodecodemustbeinfiber (packages/meteor/dynamics_nodejs.js:9) w20141112-20:08:44.306(-8)? (stderr) @ _.extend.get (packages/meteor/dynamics_nodejs.js:21) w20141112-20:08:44.306(-8)? (stderr) @ object.ddp.randomstream (packages/ddp/random_stream.js:69) w20141112-20:08:44.306(-8)? (stderr) @ self._makenewid (packages/mongo/collection.js:72) w20141112-20:08:44.306(-8)? (stderr) @ mongo.collection.(anonymous function) [as insert] (packages/mongo/collection.js:485) w20141112-20:08:44.307(-8)? (stderr) @ csvadv.<anonymous> (server/startup.coffee:16:13) w20141112-20:08:44.307(-8)? (stderr) @ csvadv.emit (events.js:95:17) w20141112-20:08:44.307(-8)? (stderr) @ csvadv.<anonymous> (/users/samuel_chordas/currentclasses/csci477a/jpl/jatatwo/packages/npm-container/.build.npm-container/npm/node_modules/csvtojson/libs/core/init_onend.js:9:10) w20141112-20:08:44.307(-8)? (stderr) @ csvadv.emit (events.js:117:20) w20141112-20:08:44.307(-8)? (stderr) @ _stream_readable.js:929:16 => exited code: 8

which able rid of wrapping function in fiber next code not write collection:

if meteor.isserver @fiber = meteor.npmrequire("fibers") meteor.startup -> #converter class if data.find().count() 0 converter = meteor.npmrequire('csvtojson').core.converter fs = meteor.npmrequire('fs') csvfilename = '/path/to/my/file.csv' filestream = fs.createreadstream(csvfilename) #new converter instance csvconverter = new converter(constructresult: true) #end_parsed emitted 1 time parsing finished csvconverter.on "end_parsed", (jsonobj) -> fiber -> data.insert jsonobj homecoming filestream.pipe csvconverter homecoming

so tried resorting using bindenvironment shown in first block of code results in same "error("meteor code must run within fiber" error.

here collection in /lib folder:

@data = new mongo.collection 'data'

i pretty new meteor javascript , coffescript feedback appreciated.

also add together can't .run() work on fiber.

try moving definition of boundfunction outside of end_parsed event handler.

class="lang-coffee prettyprint-override">boundfunction = meteor.bindenvironment((jsonobj) -> data.insert jsonobj homecoming , (e) -> throw e ) csvconverter.on "end_parsed", (jsonobj) -> console.log jsonobj boundfunction jsonobj homecoming

i suspect "meteor code must run within fiber." error not coming data.insert meteor.bindenvironment itself. meteor.bindenvironment

is called within "meteor context" takes function binds function same "meteor context" bindenvironment called from

in implementation, time phone call bindenvironment, "meteor context" has been lost, bindenvironment can't help.

meteor coffeescript fiber

Comments

Post a Comment

Popular posts from this blog

Delphi change the assembly code of a running process -

Delphi change the assembly code of a running process - i'm trying alter address 00741fa5 has push test.009e721c . alter push test.009e71c8 . procedure callback; asm force $9e71c8 end; procedure tform2.btn1click(sender: tobject); var ppid :dword; pprocess : cardinal; begin getwindowthreadprocessid(findwindow(nil,pchar('test')), @ppid); pprocess := openprocess(process_all_access, false, ppid); injectasm(pprocess, $741fa5, 10, integer(@callback), 0); end; here injectasm function (with error checking) function injectasm(process: longword; injectaddress, injectsize, codeaddress, codesize : integer): pointer; var csize, rsize : integer; replaced : array of byte; jmp : array [0..4] of byte; jmpaddress : integer; nopv : byte; : integer; nbr: ulong_ptr; begin //injectsize must equal or greater 5, because need space our //(far) jmp wwxxyyzz instruction //if there's no space, inject in place of few instructions if injectsize ...
Read more

json - Hibernate and Jackson (java.lang.IllegalStateException: Cannot call sendError() after the response has been committed) -

json - Hibernate and Jackson (java.lang.IllegalStateException: Cannot call sendError() after the response has been committed) - hello have problem hibernate , jackson. have 2 pojos @entity @table(name = "users") public class user implements serializable { static final long serialversionuid = 4235637833262722256l; @id @generatedvalue private int id; @column(name = "creation_date") private date creationdate; @column(name = "first_name") private string firstname; @column(name = "last_name") private string lastname; @version @column(name = "version") private int version; @column(name = "e_mail") private string email; @column(name = "enabled") private boolean enabled; @column(name = "login") private string login; @column(name = "password") private string password; @jsonmanagedreference("role") @onetomany(mappedby = "user", cascade = cascadetype.all,fetch = fetchtyp...
Read more

C++ 11 "class" keyword -

C++ 11 "class" keyword - i've started using c++ 11 little bit more , have few questions on special uses of class keyword. know it's used declare class, there's 2 instances have seen don't understand: method<class t>(); and class class_name *var; why precede typename keyword class in first example, , keyword pointer in sec example? that known elaborated type specifier , necessary when class name "shadowed" or "hidden" , need explicit. class t { }; // love of god don't t t; t t2; if compiler smart, give these warnings: main.cpp:15:5: error: must utilize 'class' tag refer type 't' in scope t t2; ^ class main.cpp:14:7: note: class 't' hidden non-type declaration of 't' here t t; ^ if class not defined, deed forwards declaration. for example: template <typename t> void method() { using type = typename t::value_type; } method...
Read more