javascript - 包装socket.on作为一个 promise

我正在使用功能init作为resolve进行服务。首先，它创建一个带有连接ID的文件夹，然后在其中写入一些默认文件。应该记录该文件夹（即连接的ID），这是this.dir的目的。

以下代码很好地调用了initDir。但是，它不会调用initFiles（即，不会调用alert("here")）。我想这是因为initDir不能令人满意。

有人知道如何修改吗？

this.files = [ ... ... ];

this.dir = "public/tmp/default/";

this.initDir = function () {
    var socket = io.connect();
    return socket.on('id', function (id) {
        var dir = "public/tmp/" + id + "/";
        return $http.post('mkdir', { dir: dir })
            .then(function () {
                this.dir = dir;
            })
    })
}

this.initFiles = function (dir, files) {
    return $http.post('writeFile', { dir: dir, file: files[0] })
        .then(function (res) {
            $http.post('writeFile', { dir: dir, file: files[1] })
                .then(function (res) {
                    console.log("saved 2 files")
                })
            })
    })
}

this.init = function () {
    return this.initDir()
        .then(function (res) {
            alert("here");
            this.initFiles(this.dir, this.files)
        })
}

在服务器端，它仅在每个连接之后发送连接ID：

io.sockets.on('connection', function (socket) {
    socket.emit('id', socket.id);
}

编辑1：按照@epiqueras的回答，我修改了代码。以下代码调用inside init，但是不调用inside initDir...。

var dirP = "public/tmp/default/";

this.initDir = function () {
    return new Promise(function (resolve, reject) {
        alert("inside initDir")
        var socket = io.connect();
        socket.on('id', function (id) {
            var dir = "public/tmp/" + id + "/";
            $http.post('mkdir', { dir: dir })
                .then(function () {
                    dirP = dir;
                    resolve(dirP)
                })
        })
    })
}

this.init = function (files) {
    alert("inside init");
    return initDir
        .then(function (dir) {
            alert("before initFiles");
            this.initFiles(dir, files)
        })
}

编辑2：将initDir.then更改为this.initDir().then之后，我有以下代码。它很好地显示了inside init，inside initDir，before initFiles。但是，它不显示inside initFiles或写入文件。

this.initDir = function () {
    return new Promise(function (resolve, reject) {
        console.log("inside initDir")
        var socket = io.connect();
        socket.on('id', function (id) {
            var dir = "public/tmp/" + id + "/";
            $http.post('mkdir', { dir: dir })
                .then(function () {
                    dirP = dir;
                    resolve(dirP)
                })
        })
    })
};

this.initFiles = function (dir, files) {
    console.log("initFiles: " + dir);
    return $http.post('writeFile', { dir: dir, file: files[0] })
        .then(function (res) {
            $http.post('writeFile', { dir: dir, file: files[1] })
                .then(function (res) {
                    console.log("saved 2 files")
                })
            })
    })
}

this.init = function (files) {
    console.log("inside init");
    return this.initDir().then(function (dir) {
        console.log("before initFiles " + dir + JSON.stringify(files));
        this.initFiles(dir, files)
    })
};

最佳答案

它不起作用，因为socket.on不会返回其回调的返回值。

尝试将代码包装成一个Promise，并在回调内部解析，而不仅仅是返回。

initDir() {
    return new Promise(function(resolve, reject) {
        socket.on.....
            $http.post.....then(resolve)
    }
}

确保您返回的是新的Promise，并且正在解决您要等待的最终值。