_ = require 'underscore' fs = require 'fs' File = require 'file' Point = require 'point' Range = require 'range' EventEmitter = require 'event-emitter' UndoManager = require 'undo-manager' BufferChangeOperation = require 'buffer-change-operation' Anchor = require 'anchor' AnchorRange = require 'anchor-range' Git = require 'git' module.exports = class Buffer @idCounter = 1 stoppedChangingDelay: 300 stoppedChangingTimeout: null undoManager: null cachedDiskContents: null cachedMemoryContents: null conflict: false lines: null file: null anchors: null anchorRanges: null refcount: 0 git: null constructor: (path, @project) -> @id = @constructor.idCounter++ @anchors = [] @anchorRanges = [] @lines = [''] if path throw "Path '#{path}' does not exist" unless fs.exists(path) @setPath(path) @reload() else @setText('') @undoManager = new UndoManager(this) destroy: -> throw new Error("Destroying buffer twice with path '#{@getPath()}'") if @destroyed @file?.off() @destroyed = true @project?.removeBuffer(this) retain: -> @refcount++ this release: -> @refcount-- @destroy() if @refcount <= 0 this subscribeToFile: -> @file.on "contents-change", => if @isModified() @conflict = true @updateCachedDiskContents() @trigger "contents-conflicted" else @reload() @file.on "remove", => @updateCachedDiskContents() @trigger "contents-modified", {differsFromDisk: true} @file.on "move", => @trigger "path-change", this reload: -> @updateCachedDiskContents() @setText(@cachedDiskContents) updateCachedDiskContents: -> @cachedDiskContents = @file.read() getBaseName: -> @file?.getBaseName() getPath: -> @file?.getPath() setPath: (path) -> return if path == @getPath() @git = new Git(path) @file?.off() @file = new File(path) if @file.exists() @file.read() @subscribeToFile() @trigger "path-change", this getExtension: -> if @getPath() @getPath().split('/').pop().split('.').pop() else null getText: -> @cachedMemoryContents ?= @lines.join('\n') setText: (text) -> @change(@getRange(), text) getRange: -> new Range([0, 0], [@getLastRow(), @getLastLine().length]) getTextInRange: (range) -> range = Range.fromObject(range) if range.start.row == range.end.row return @lines[range.start.row][range.start.column...range.end.column] multipleLines = [] multipleLines.push @lines[range.start.row][range.start.column..] # first line for row in [range.start.row + 1...range.end.row] multipleLines.push @lines[row] # middle lines multipleLines.push @lines[range.end.row][0...range.end.column] # last line return multipleLines.join '\n' getLines: -> @lines lineForRow: (row) -> @lines[row] lineLengthForRow: (row) -> @lines[row].length rangeForRow: (row, { includeNewline } = {}) -> if includeNewline and row < @getLastRow() new Range([row, 0], [row + 1, 0]) else new Range([row, 0], [row, @lineLengthForRow(row)]) getLineCount: -> @getLines().length getLastRow: -> @getLines().length - 1 getLastLine: -> @lineForRow(@getLastRow()) getEofPosition: -> lastRow = @getLastRow() new Point(lastRow, @lineLengthForRow(lastRow)) characterIndexForPosition: (position) -> position = Point.fromObject(position) index = 0 index += @lineLengthForRow(row) + 1 for row in [0...position.row] index + position.column positionForCharacterIndex: (index) -> row = 0 while index >= (lineLength = @lineLengthForRow(row) + 1) index -= lineLength row++ new Point(row, index) deleteRow: (row) -> @deleteRows(row, row) deleteRows: (start, end) -> startPoint = null endPoint = null if end == @getLastRow() if start > 0 startPoint = [start - 1, @lineLengthForRow(start - 1)] else startPoint = [start, 0] endPoint = [end, @lineLengthForRow(end)] else startPoint = [start, 0] endPoint = [end + 1, 0] @change(new Range(startPoint, endPoint), '') insert: (point, text) -> @change(new Range(point, point), text) delete: (range) -> @change(range, '') change: (oldRange, newText) -> oldRange = Range.fromObject(oldRange) operation = new BufferChangeOperation({buffer: this, oldRange, newText}) range = @pushOperation(operation) range clipPosition: (position) -> { row, column } = Point.fromObject(position) row = 0 if row < 0 column = 0 if column < 0 row = Math.min(@getLastRow(), row) column = Math.min(@lineLengthForRow(row), column) new Point(row, column) prefixAndSuffixForRange: (range) -> prefix: @lines[range.start.row][0...range.start.column] suffix: @lines[range.end.row][range.end.column..] replaceLines: (startRow, endRow, newLines) -> @lines[startRow..endRow] = newLines @cachedMemoryContents = null @conflict = false if @conflict and !@isModified() pushOperation: (operation, editSession) -> if @undoManager @undoManager.pushOperation(operation, editSession) else operation.do() transact: (fn) -> @undoManager.transact(fn) undo: (editSession) -> @undoManager.undo(editSession) redo: (editSession) -> @undoManager.redo(editSession) save: -> @saveAs(@getPath()) saveAs: (path) -> unless path then throw new Error("Can't save buffer with no file path") @trigger 'before-save' @setPath(path) @cachedDiskContents = @getText() @file.write(@getText()) @subscribeToFile() @trigger 'after-save' isModified: -> if @file @getText() != @cachedDiskContents else not @isEmpty() isInConflict: -> @conflict isEmpty: -> @lines.length is 1 and @lines[0].length is 0 getAnchors: -> new Array(@anchors...) addAnchor: (options) -> anchor = new Anchor(this, options) @anchors.push(anchor) anchor addAnchorAtPosition: (position, options) -> anchor = @addAnchor(options) anchor.setBufferPosition(position) anchor addAnchorRange: (range, editSession) -> anchorRange = new AnchorRange(range, this, editSession) @anchorRanges.push(anchorRange) anchorRange removeAnchor: (anchor) -> _.remove(@anchors, anchor) removeAnchorRange: (anchorRange) -> _.remove(@anchorRanges, anchorRange) matchesInCharacterRange: (regex, startIndex, endIndex) -> text = @getText() matches = [] regex.lastIndex = startIndex while match = regex.exec(text) matchLength = match[0].length matchStartIndex = match.index matchEndIndex = matchStartIndex + matchLength if matchEndIndex > endIndex regex.lastIndex = 0 if matchStartIndex < endIndex and submatch = regex.exec(text[matchStartIndex...endIndex]) submatch.index = matchStartIndex matches.push submatch break matchEndIndex++ if matchLength is 0 regex.lastIndex = matchEndIndex matches.push match matches scan: (regex, iterator) -> @scanInRange(regex, @getRange(), iterator) scanInRange: (regex, range, iterator, reverse=false) -> range = Range.fromObject(range) global = regex.global flags = "gm" flags += "i" if regex.ignoreCase regex = new RegExp(regex.source, flags) startIndex = @characterIndexForPosition(range.start) endIndex = @characterIndexForPosition(range.end) matches = @matchesInCharacterRange(regex, startIndex, endIndex) lengthDelta = 0 keepLooping = null replacementText = null stop = -> keepLooping = false replace = (text) -> replacementText = text matches.reverse() if reverse for match in matches matchLength = match[0].length matchStartIndex = match.index matchEndIndex = matchStartIndex + matchLength startPosition = @positionForCharacterIndex(matchStartIndex + lengthDelta) endPosition = @positionForCharacterIndex(matchEndIndex + lengthDelta) range = new Range(startPosition, endPosition) keepLooping = true replacementText = null iterator(match, range, { stop, replace }) if replacementText? @change(range, replacementText) lengthDelta += replacementText.length - matchLength unless reverse break unless global and keepLooping backwardsScanInRange: (regex, range, iterator) -> @scanInRange regex, range, iterator, true isRowBlank: (row) -> not /\S/.test @lineForRow(row) previousNonBlankRow: (startRow) -> return null if startRow == 0 startRow = Math.min(startRow, @getLastRow()) for row in [(startRow - 1)..0] return row unless @isRowBlank(row) null nextNonBlankRow: (startRow) -> lastRow = @getLastRow() if startRow < lastRow for row in [(startRow + 1)..lastRow] return row unless @isRowBlank(row) null usesSoftTabs: -> for line in @getLines() if match = line.match(/^\s/) return match[0][0] != '\t' undefined logLines: (start=0, end=@getLastRow())-> for row in [start..end] line = @lineForRow(row) console.log row, line, line.length getGit: -> @git checkoutHead: -> path = @getPath() return unless path if @git?.checkoutHead(path) @trigger 'git-status-change' scheduleStoppedChangingEvent: -> clearTimeout(@stoppedChangingTimeout) if @stoppedChangingTimeout stoppedChangingCallback = => @stoppedChangingTimeout = null @trigger 'contents-modified', {differsFromDisk: @isModified()} @stoppedChangingTimeout = setTimeout(stoppedChangingCallback, @stoppedChangingDelay) fileExists: -> @file.exists() _.extend(Buffer.prototype, EventEmitter)