summaryrefslogtreecommitdiff
path: root/heat/cloudinit/part_handler.py
blob: 5e8cc84613c0c3e583e21570b27e3d1276e44828 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
#part-handler

#    Licensed under the Apache License, Version 2.0 (the "License"); you may
#    not use this file except in compliance with the License. You may obtain
#    a copy of the License at
#
#         http://www.apache.org/licenses/LICENSE-2.0
#
#    Unless required by applicable law or agreed to in writing, software
#    distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
#    WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
#    License for the specific language governing permissions and limitations
#    under the License.

import datetime
import errno
import os
import sys


def list_types():
    return(["text/x-cfninitdata"])


def handle_part(data, ctype, filename, payload):
    if ctype == "__begin__":
        try:
            os.makedirs('/var/lib/heat-cfntools', int("700", 8))
        except OSError:
            ex_type, e, tb = sys.exc_info()
            if e.errno != errno.EEXIST:
                raise
        return

    if ctype == "__end__":
        return

    log = open('/var/log/part-handler.log', 'a')
    try:
        timestamp = datetime.datetime.now()
        log.write('%s filename:%s, ctype:%s\n' % (timestamp, filename, ctype))
    finally:
        log.close()

    if ctype == 'text/x-cfninitdata':
        f = open('/var/lib/heat-cfntools/%s' % filename, 'w')
        try:
            f.write(payload)
        finally:
            f.close()

        # TODO(sdake) hopefully temporary until users move to heat-cfntools-1.3
        f = open('/var/lib/cloud/data/%s' % filename, 'w')
        try:
            f.write(payload)
        finally:
            f.close()